NodeJS环境下如何将GraphQL上传得到的createReadStream转换为buffer

createReadStream 返回的是 Node.js 标准可读流，只需要拼接流输出的所有数据块即可得到 Buffer 对象，以下是两种常用实现方式：

• 回调写法

const readStream = createReadStream();
const bufferChunks = [];

// 监听流数据事件，收集所有数据块
readStream.on('data', (chunk) => {
  bufferChunks.push(chunk);
});

// 流读取完成后拼接为完整Buffer
readStream.on('end', () => {
  const resultBuffer = Buffer.concat(bufferChunks);
  // 此处直接将resultBuffer传递给目标函数即可
});

// 必须监听错误事件，避免未捕获异常导致程序崩溃
readStream.on('error', (error) => {
  console.error('文件流读取失败：', error);
});

• async/await 写法
  可以将转换逻辑封装为Promise工具函数，适配异步编程场景：

// 流转Buffer工具函数
const streamToBuffer = (readStream) => {
  return new Promise((resolve, reject) => {
    const bufferChunks = [];
    readStream.on('data', (chunk) => bufferChunks.push(chunk));
    readStream.on('end', () => resolve(Buffer.concat(bufferChunks)));
    readStream.on('error', reject);
  });
};

// 调用示例
const fileBuffer = await streamToBuffer(createReadStream());

注意：大文件场景下不建议使用该方案，完整Buffer会占用和文件大小对等的内存，大文件处理优先使用流式传输逻辑。

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