使用Node.js生成含CSV的ZIP并从函数返回流缓冲区时出现未定义问题的求助

首先，你的代码核心问题在于函数没有返回一个有效的Promise对象，导致await无法正确等待异步操作完成。

你在finish事件回调里写了return Promise.resolve(...)，但这个return属于回调函数本身，并不是createZipFromCsv函数的返回值。createZipFromCsv执行时会同步完成创建流、初始化archiver这些步骤，之后直接结束（默认返回undefined），而finish事件是异步触发的——这就是为什么外部的console.log(buffer)先输出undefined，回调里的日志才在之后输出有效缓冲区内容。

修复后的代码 #

我们需要把整个异步逻辑包裹在Promise中，手动控制resolve和reject的时机：

const archiver = require('archiver');
const streamBuffers = require("stream-buffers");

async function createZipFromCsv(csv) {
  return new Promise((resolve, reject) => {
    var myWritableStreamBuffer = new streamBuffers.WritableStreamBuffer({
      initialSize: (100 * 1024), // 初始100KB
      incrementAmount: (10 * 1024) // 每次溢出扩容10KB
    });

    // 流写入完成时，返回缓冲区内容
    myWritableStreamBuffer.on('finish', () => {
      resolve(myWritableStreamBuffer.getContents());
    });

    const archive = archiver('zip');
    
    // 处理archiver错误，避免Promise挂起
    archive.on('error', (err) => {
      reject(err);
    });

    archive.pipe(myWritableStreamBuffer);
    archive.append(csv, { name: 'csvName.csv' });
    archive.finalize();
  });
}

关键修改点 #

• 让createZipFromCsv返回Promise，确保外部await能等待异步操作完成
• 在finish事件触发时调用resolve，传递缓冲区内容
• 添加archiver错误监听，打包出错时调用reject抛出错误，避免Promise一直处于pending状态

现在再调用你的代码：

const buffer = await createZipFromCsv("some,csv,data");
console.log(buffer); // 会正确输出ZIP文件的缓冲区内容

这样就能保证await等待到流写入完成后，再拿到正确的缓冲区数据了。

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