AWS S3 SDK v3中获取Node.js Readable流的实现问题求助

嘿，我之前升级AWS S3 SDK到v3的时候也踩过这个类型不兼容的坑！确实，v3返回的ReadableStream是浏览器标准的实现，和Node.js内置stream/web模块里的ReadableStream在类型定义上有差异，直接用Readable.fromWeb()就会报你遇到的那个类型错误。给你两个实用的解决办法：

方法一：用AWS官方提供的流转换工具包（推荐） #

AWS专门出了@aws-sdk/util-stream-node这个工具包，就是用来解决SDK返回的Web流和Node流之间的转换问题的，省心又靠谱：

1. 先安装依赖：

npm install @aws-sdk/util-stream-node

2. 修改你的代码：

import { Readable } from 'node:stream';
import { toNodeReadable } from '@aws-sdk/util-stream-node';

public async getFileStream(filename: string): Promise<Readable> {
  const response = await this.s3.getObject({
    Bucket: this.bucket,
    Key: filename,
  });

  // 记得处理Body为空的情况，避免报错
  if (!response.Body) {
    throw new Error(`File ${filename} has no content`);
  }

  return toNodeReadable(response.Body as ReadableStream);
}

这个工具函数是官方维护的，完美适配SDK返回的流，类型问题直接解决，不用自己折腾兼容逻辑。

方法二：手动用PassThrough中转（无额外依赖） #

如果你不想加新的依赖包，可以用Node.js内置的PassThrough流来做中转，把Web流的数据导进去：

import { Readable, PassThrough } from 'node:stream';

public async getFileStream(filename: string): Promise<Readable> {
  const response = await this.s3.getObject({
    Bucket: this.bucket,
    Key: filename,
  });

  if (!response.Body) {
    throw new Error(`File ${filename} has no content`);
  }

  const passThrough = new PassThrough();
  const webStream = response.Body as ReadableStream;

  // 将Web流的数据导入PassThrough
  await webStream.pipeTo(new WritableStream({
    write(chunk) {
      passThrough.write(chunk);
    },
    close() {
      passThrough.end();
    },
    abort(err) {
      passThrough.destroy(err);
    }
  }));

  return passThrough;
}

PassThrough相当于一个数据管道，把Web流的每一段数据都转发到Node流里，最后返回的passThrough就是标准的Node Readable流了。

备注：内容来源于stack exchange，提问作者SebastianR