在AWS Lambda中用ExcelJS读取S3 CSV：MDN流与Node.js流兼容问题

问题核心 #

AWS SDK v3从S3获取文件时返回的data.Body是MDN标准的Web流（ReadableStream），但ExcelJS仅支持Node.js原生Readable流，导致无法直接初始化Workbook对象。

SDK响应类型说明：

const data: GetObjectCommandOutput = await s3Client.send(command);
// data.Body 类型：SdkStream<Readable | ReadableStream<any> | Blob | undefined> | undefined

已尝试的无效方法 #

• 转换Web流后用Node.js流包装：

  const readableStream: ReadableStream = data.Body!.transformToWebStream();
  const expectedNodejsStream = new Readable().wrap(readableStream);
  

  失败原因：wrap方法仅支持Node.js原生ReadableStream，不兼容MDN Web流。

• 尝试用pipe转换：

  const nodeStream = new stream.Writable();
  (data.Body! as Readable).pipe(nodeStream);
  

  失败原因：运行时无法将data.Body强制转换为Node.js Readable类型，抛出异常。

• 直接传入Web流给ExcelJS：

  const wb = new Excel.Workbook();
  wb.xlsx.read(nodeStream); // 无法工作
  // 或
  new Excel.stream.xlsx.WorkbookReader(data.Body!.transformToWebStream()); // 无法工作
  

解决方案 #

能否直接用MDN Web流初始化ExcelJS？ #

不能，ExcelJS目前没有内置对Web流的支持，必须转换为Node.js原生流。

无需自行实现转换的方法 #

使用AWS SDK v3官方提供的transformToNodeStream()方法，直接将SdkStream转换为Node.js原生Readable流，这是最简便且可靠的方式。

示例代码：

import { Readable } from 'stream';
import Excel from 'exceljs';
import { S3Client, GetObjectCommand } from '@aws-sdk/client-s3';

const s3Client = new S3Client({});

async function processS3File() {
  const command = new GetObjectCommand({
    Bucket: '你的存储桶名称',
    Key: '目标文件的Key（如xxx.csv）'
  });

  const data = await s3Client.send(command);
  
  // 关键：用官方方法转换为Node.js原生流
  if (!data.Body) {
    throw new Error('S3文件内容为空');
  }
  const nodeStream = data.Body.transformToNodeStream() as Readable;

  // 注意：处理CSV文件请用csv.read，而非xlsx.read
  const wb = new Excel.Workbook();
  await wb.csv.read(nodeStream);

  // 后续处理逻辑示例
  const worksheet = wb.getWorksheet(1);
  worksheet.eachRow({ includeEmpty: false }, (row, rowNumber) => {
    console.log(`第${rowNumber}行数据：`, row.values);
  });
}

注意事项 #

1. 如果你处理的是CSV文件，必须使用wb.csv.read()方法，而非wb.xlsx.read()，避免格式不匹配导致的错误。
2. 实际代码中务必增加data.Body的空值判断，防止运行时异常。
3. 该方法要求AWS SDK v3版本≥3.121，你的当前版本（^3.121）已满足要求。

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