Node.js中busboy的finish事件无法正常返回数据问题求解

返回值为undefined是三个核心问题导致的：

• 事件回调的返回值不会传递到外层函数：你在busboy.on('finish', () => { return finalData })中写的return，只会把值返回给busboy内部的事件调度逻辑，根本不会作为外层processRequest函数的返回值传给调用方。
• 异步时序不匹配：busboy触发finish事件仅代表它完成了multipart请求结构的拆分，不代表你后续的文件流解析、CSV/Excel格式转换逻辑已经执行完毕。尤其是CSV解析部分你又嵌套了一层异步流处理，busboy触发finish时，CSV解析大概率还没跑完，此时finalData还未被赋值，就算能拿到回调返回值也会是undefined。
• 整体写法问题：你用同步函数的写法封装全异步的事件驱动逻辑（busboy、文件流、CSV解析全是异步逻辑），同步函数执行栈清空时，异步解析逻辑还在运行，调用方自然拿不到结果。

你测试时在finish回调里打印能看到完整数据，只是小文件场景下的时序巧合：console.log执行时异步解析刚好跑完完成了赋值，一旦文件体积变大、解析耗时增加，就算在finish回调里打印也会拿到undefined。

把processRequest改写成返回Promise的函数，等所有解析逻辑（包括内部的CSV/Excel解析）全部完成后再返回结果，所有错误场景统一抛出。
修复后的代码如下：

const Busboy = require('busboy');
const XLSX = require('xlsx');
const { Readable } = require('stream');
const CSV = require('csv-parser'); // 按你实际引入的CSV解析依赖调整

class FileFormatError extends Error {
  constructor(message) {
    super(message);
    this.name = 'FileFormatError';
  }
}

// 保留你原有的excel转json逻辑即可
const excelToJson = (workbook) => {
  const firstSheetName = workbook.SheetNames[0];
  const worksheet = workbook.Sheets[firstSheetName];
  return XLSX.utils.sheet_to_json(worksheet);
};

/**
 * 解析multipart请求中的上传文件，返回结构化解析结果
 * @param {object} req Cloud Function请求对象
 * @returns {Promise<Array|object>} 解析后的CSV/Excel数据
 */
const processRequest = (req) => {
  return new Promise((resolve, reject) => {
    const busboy = Busboy({ headers: req.headers });
    const allowedFormats = [
      'application/vnd.ms-excel',
      'text/csv',
      'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'
    ];

    busboy.on('file', (fieldname, file, fileInfo) => {
      const { mimeType } = fileInfo;
      // 格式校验不通过时先消费流避免内存泄漏，再返回错误
      if (!allowedFormats.includes(mimeType)) {
        file.resume();
        return reject(new FileFormatError('File must be excel or csv'));
      }
      // 非指定字段的文件直接跳过消费
      if (fieldname !== 'file') {
        file.resume();
        return;
      }

      const bytes = [];
      file.on('data', (chunk) => bytes.push(chunk));
      file.on('error', (err) => reject(err));

      file.on('end', () => {
        const buffer = Buffer.concat(bytes);
        // 处理Excel格式
        if (mimeType === 'application/vnd.ms-excel' ||
            mimeType === 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet') {
          try {
            const workbook = XLSX.read(buffer, { type: 'buffer' });
            const jsonData = excelToJson(workbook);
            resolve(jsonData);
          } catch (err) {
            reject(err);
          }
        }
        // 处理CSV格式
        if (mimeType === 'text/csv') {
          const csvData = [];
          const stream = Readable.from(buffer.toString());
          stream.pipe(CSV.parse({ delimiter: ',' }))
            .on('error', (err) => reject(err))
            .on('data', (row) => csvData.push(row))
            .on('end', () => {
              resolve(csvData);
            });
        }
      });
    });

    busboy.on('error', (err) => reject(err));
    // 不需要在busboy的finish事件里返回结果，等具体文件解析完成后再resolve即可
    busboy.end(req.rawBody);
  });
};

processRequest现在是异步函数，在Cloud Function主逻辑里调用时需要加await：

exports.uploadHandler = async (req, res) => {
  try {
    const parsedData = await processRequest(req);
    // 拿到解析结果后即可写入Firestore
    // await db.collection('your-collection').add({ data: parsedData, uploadTime: Date.now() });
    res.status(200).send({ success: true, count: parsedData.length });
  } catch (err) {
    res.status(400).send({ error: err.message });
  }
};

• 原代码中大量变量未加const/let声明，会污染全局作用域，修复版本已全部补全声明
• 遇到不符合要求的文件流必须调用file.resume()消费流，否则会造成请求挂起、内存泄漏
• 原代码中file.on('end', async () => {})的async标记没有任何作用，因为回调内没有await逻辑，已移除

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