AWS Lambda将流管道传输到S3 PutObject出现NotImplemented错误求助

该NotImplemented报错为AWS S3使用PutObject接口上传未知大小流的典型报错：
AWS SDK v3的PutObjectCommand不会自动计算流式Body的Content-Length请求头，而S3的PutObject接口要求必须传入明确的Content-Length，不支持Chunked编码的未知长度上传，因此返回功能未实现错误。

有两种可行的修复方式，优先推荐第一种：

方案1：先生成压缩包到临时存储，拿到明确大小后再上传 #

你已经用到了Lambda的/tmp临时存储，可以直接把tar.gz先写入本地文件，再用文件流上传，SDK会自动识别文件大小填充Content-Length头：

const tar = require("tar");
const fs = require("fs");
const { S3Client, PutObjectCommand } = require("@aws-sdk/client-s3");

// 补充S3客户端初始化，注意区域和桶一致
const s3 = new S3Client({ region: process.env.AWS_REGION });

const buildDockerFile = {
  stock: async (repository, tag, repositoryId) => {
    const dockerfileContent = `FROM ${repository}:${tag}`;
    const dockerfilePath = "/tmp/Dockerfile";
    const tarPath = "/tmp/build-context.tar.gz";
    
    // 写入Dockerfile到临时存储
    fs.writeFileSync(dockerfilePath, dockerfileContent);
    // 压缩包直接写入临时文件，无需PassThrough流
    await tar.c({ gzip: true, file: tarPath }, [dockerfilePath]);
    
    const params = {
      Body: fs.createReadStream(tarPath),
      Bucket: process.env.DOCKER_IMAGES_BUCKET,
      Key: `${repositoryId}/${tag}/build-context.tar.gz`,
    };

    await s3.send(new PutObjectCommand(params));
    // 可选：用完删除临时文件避免占用/tmp空间
    fs.unlinkSync(dockerfilePath);
    fs.unlinkSync(tarPath);
  }
};

方案2：改用分片上传接口处理流式内容 #

如果你不想占用临时存储，可以用@aws-sdk/lib-storage包的Upload类，它会自动将流分块做分片上传，不需要提前知道完整内容大小：

1. 先安装依赖：npm install @aws-sdk/lib-storage
2. 修改上传逻辑：

const { Upload } = require("@aws-sdk/lib-storage");
// 其余初始化、Dockerfile生成、压缩流逻辑和原有代码一致
const upload = new Upload({
  client: s3,
  params: {
    Body: pass, // 直接传入原有PassThrough流即可
    Bucket: process.env.DOCKER_IMAGES_BUCKET,
    Key: `${repositoryId}/${tag}/build-context.tar.gz`,
  }
});
await upload.done();

• 确认Lambda执行角色有对应S3桶的s3:PutObject权限
• Lambda的/tmp目录最大容量为10GB，只要你的构建上下文压缩包不超过该阈值就可以使用方案1
• 确认S3客户端初始化的区域和目标桶的区域一致

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