将一个流管道传输到S3.upload（）

Question

我目前正在使用一个名为s3-upload-stream的Node.js插件，将非常大的文件传输到Amazon S3。它使用multipart API，并且在很大程度上工作得很好。

是否有一种方法可以使aws-sdks3.upload()成为我可以将流管道传输到的东西？

Answer 1

将S3upload()函数与node.jsstream.passthrough()流包装起来。

这里有一个例子：

inputStream
  .pipe(uploadFromStream(s3));

function uploadFromStream(s3) {
  var pass = new stream.PassThrough();

  var params = {Bucket: BUCKET, Key: KEY, Body: pass};
  s3.upload(params, function(err, data) {
    console.log(err, data);
  });

  return pass;
}