Google Cloud Function中Busboy无法正常工作（Postman测试）

你的代码存在几个关键问题导致无法完成图片上传到Cloud Storage的操作，以下是具体问题及修正后的实现：

核心问题点 #

• 变量作用域错误：finish事件回调中引用的filename仅在file事件的局部作用域内有效，外部访问会触发未定义错误
• 文件大小获取错误：Busboy的file是可读流对象，没有length属性，无法直接获取文件大小
• 缺失GCS存储逻辑：当前代码仅打印文件元信息，未实现将文件流上传到Cloud Storage的核心逻辑
• 响应逻辑冗余且错误：res.send()后无需再调用res.end()，且因filename未定义会导致响应失败

修正后的完整代码 #

const functions = require('@google-cloud/functions-framework');
const { Storage } = require('@google-cloud/storage');
const Busboy = require('busboy');

// 初始化Storage，替换为你的存储桶名称
const storage = new Storage();
const BUCKET_NAME = '你的存储桶名称';

functions.http('uploadImage', (req, res) => {
  // 只处理POST请求
  if (req.method !== 'POST') {
    return res.status(405).send('仅支持POST请求');
  }

  const busboy = Busboy({ headers: req.headers });
  let uploadedFilename = '';
  let fileSize = 0;

  busboy.on('file', (fieldname, file, { filename, encoding, mimetype }) => {
    uploadedFilename = filename;
    console.log('接收文件:', uploadedFilename);
    console.log('MIME类型:', mimetype);

    // 累加计算文件大小
    file.on('data', (chunk) => {
      fileSize += chunk.length;
    });

    // 将文件流直接上传到Cloud Storage
    const bucket = storage.bucket(BUCKET_NAME);
    const cloudFile = bucket.file(uploadedFilename);
    
    const writeStream = cloudFile.createWriteStream({
      metadata: {
        contentType: mimetype
      }
    });

    // 处理上传错误
    writeStream.on('error', (err) => {
      console.error('GCS上传错误:', err);
      res.status(500).send('文件上传失败');
    });

    // 上传完成后的处理
    writeStream.on('finish', () => {
      console.log('文件上传完成，大小:', fileSize, '字节');
    });

    // 将Busboy的文件流管道到GCS的写入流
    file.pipe(writeStream);
  });

  busboy.on('error', (err) => {
    console.error('文件解析错误:', err);
    res.status(500).send('文件解析失败');
  });

  busboy.on('finish', () => {
    // 确保文件名已获取到再响应
    if (uploadedFilename) {
      res.status(200).send(`文件 ${uploadedFilename} 上传成功，大小：${fileSize} 字节`);
    } else {
      res.status(400).send('未接收到文件');
    }
  });

  req.pipe(busboy);
});

Postman配置说明 #

1. 请求方法选择POST，填入你的云函数触发URL
2. 在Body标签页选择form-data
3. 添加一个字段，字段名可自定义（比如image），类型选择File
4. 在右侧选择要上传的图片文件，发送请求即可

内容的提问来源于stack exchange，提问作者manny_paz