使用 Node.js 上传 AWS S3 文件：不支持的正文有效负载错误

Question

我正在尝试让我的 node.js 后端将文件上传到 AWS S3，它是从我的前端的发布请求中获得的。这就是我的函数的样子：

async function uploadFile(file){

  var uploadParams = {Bucket: '<bucket-name>', Key: file.name, Body: file};

  s3.upload (uploadParams, function (err, data) {

    if (err) {

      console.log("Error", err);

    } if (data) {

      console.log("Upload Success", data.Location);

    }

  });

}

当我尝试以这种方式上传文件时，我收到了 Unsupported Body Payload 错误...

我过去使用 fileStream.createReadStream() 来上传文件保存在服务器上的目录中，但是创建 fileStream 对我不起作用，因为这里没有要传递的路径参数。

编辑：文件对象是在我的 Web 应用程序的 Angular 前端中创建的。这是用户上传文件的相关html代码：

<div class="form-group">

    <label for="file">Choose File</label>

    <input type="file" id="file"(change)="handleFileInput($event.target.files)">

</div>

如果事件发生，handleFileInput(files: FileList)则调用相应组件中的方法：

  handleFileInput(files: FileList) {

    // should result in array in case multiple files are uploaded

    this.fileToUpload = files.item(0);

    // actually upload the file

    this.uploadFileToActivity();

    // used to check whether we really received the file

    console.log(this.fileToUpload);

    console.log(typeof this.fileToUpload)

  }

  uploadFileToActivity() {

    this.fileUploadService.postFile(this.fileToUpload).subscribe(data => {

      // do something, if upload success

      }, error => {

        console.log(error);

      });

  }

文件上传服务的postFile(fileToUpload: File)方法用于发出 post 请求：

  postFile(fileToUpload: File): Observable<Boolean> {

    console.log(fileToUpload.name);

    const endpoint = '/api/fileupload/single';

    const formData: FormData = new FormData();

    formData.append('fileKey', fileToUpload, fileToUpload.name);

    return this.httpClient

      .post(endpoint, formData/*, { headers: yourHeadersConfig }*/)

      .pipe(

        map(() => { return true; }),

        catchError((e) => this.handleError(e)),

      );

  }

非常感谢您帮助解决这个问题！

Answer 1

最好的方法是流式传输文件。假设你是。从磁盘读取它。你可以这样做const fs = require("fs");const aws = require("aws-sdk");const s3Client = new aws.S3();const Bucket = 'somebucket';const stream = fs.createReadStream("file.pdf");const Key = stream.path;const response = await s3Client.upload({Bucket, Key, Body: stream}).promise();console.log(response);