amazon-web-services - 来自存储桶的 AWS s3 V3 Javascript SDK 流文件 (GetObjectCommand)

Question

我查看了 AWS 码头和堆栈溢出(甚至转到了谷歌的第 4 页!!!)，但我终生无法弄清楚如何从 S3 流式传输文件。 V3 的文档非常无用，我找到的所有示例都来自 V2。
V3 使用的发送通用只返回一个 promise ，那么我如何获取流并通过管道传输它而不是等待整个文件(它需要通过管道传输到加密算法然后传输到响应流)

this.s3.send(
  new GetObjectCommand({
    Bucket: '...',
    Key: key,
  }),
);

我可以通过将流作为正文进行上传，我必须在这里做类似的事情吗？

  uploadToAws(key) {
    const pass = new PassThrough();

    return {
      writeStream: pass,
      promise: this.s3.send(
        new PutObjectCommand({
          Bucket: '...',
          Key: key,
          Body: pass,
          ServerSideEncryption: '...',
          ContentLength: 37,
        }),
      ),
    };
  }

Answer 1

Body来自 GetObjectCommand是可读流( https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-s3/interfaces/getobjectcommandoutput.html#body )。
所以你可以这样做:

const command = new GetObjectCommand({
    Bucket
    Key,
});
const item = await s3Client.send(command);
item.Body.pipe(createWriteStream(fileName));