Node.js API中AWS SDK V2转V3最少代码变更迁移的疑问

是的，你必须修改getObject()的响应处理代码，但可以通过AWS SDK v3提供的工具函数把改动降到最小。

原因说明 #

AWS SDK v3的底层设计和v2存在差异，即便是在兼容v2的调用模式下，S3 getObject()的响应体也从v2的Buffer改成了ReadableStream——这是v3为优化大对象处理、降低内存占用做的默认调整，无法通过配置回退到v2的Buffer返回形式。

最小改动方案 #

使用AWS SDK v3的@aws-sdk/util-stream-node（或@aws-sdk/util-stream）包中的toArray()工具，把ReadableStream转换成Buffer，原代码中处理Buffer的逻辑可以完全保留。

示例对比

v2原代码：

const AWS = require('aws-sdk');
const s3 = new AWS.S3({ region: 'us-east-1' });

async function fetchS3Content() {
  const { Body } = await s3.getObject({ Bucket: 'my-bucket', Key: 'file.txt' }).promise();
  // 直接处理Buffer
  const content = Body.toString('utf-8');
  console.log(content);
}

v3兼容改造后代码：

const { S3, GetObjectCommand } = require('@aws-sdk/client-s3');
const { toArray } = require('@aws-sdk/util-stream-node');
const s3 = new S3({ region: 'us-east-1' });

async function fetchS3Content() {
  const response = await s3.send(new GetObjectCommand({ Bucket: 'my-bucket', Key: 'file.txt' }));
  // 仅新增这一步：将流转为Buffer
  const bodyBuffer = Buffer.concat(await toArray(response.Body));
  // 原逻辑完全复用
  const content = bodyBuffer.toString('utf-8');
  console.log(content);
}

额外优化 #

如果代码中有大量类似的流转Buffer操作，可以封装工具函数统一处理，进一步减少重复改动：

const { toArray } = require('@aws-sdk/util-stream-node');

async function streamToBuffer(stream) {
  return Buffer.concat(await toArray(stream));
}

之后在需要的地方直接调用const bodyBuffer = await streamToBuffer(response.Body)即可。

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