将 GetObject (v2) 迁移到 GetObjectCommand (v3) - aws-sdk

Question

我正在尝试将 Express 端点从 aws-sdk for JavaScript 的 v2 迁移到 v3。端点是 AWS S3 的文件下载器。

在版本 2 中，我将 GetObject 的结果以可读流的形式传回给浏览器。在版本 3 中，同样的技术失败并出现错误：

TypeError: data.Body.createReadStream is not a function

如何处理从新 GetObjectCommand 返回的数据？它是一个斑点吗？我正在努力在 v3 SDK docs.

中找到任何有用的东西

这是端点的两个版本：

import AWS from 'aws-sdk'
import dotenv from 'dotenv'

import { GetObjectCommand, S3Client } from '@aws-sdk/client-s3'

dotenv.config()

// VERSION 3 DOWNLOADER - FAILS
const getFileFromS3v3 = async (req, res) => {
  const client = new S3Client({ region: 'us-west-2' })
  const params = {
    Bucket: process.env.AWS_BUCKET,
    Key: 'Tired.pdf',
  }

  const command = new GetObjectCommand(params)

  try {
    const data = await client.send(command)
    console.log(data)
    data.Body.createReadStream().pipe(res)
  } catch (error) {
    console.log(error)
  } 
}

// VERSION 2 DOWNLOADER - WORKS
const getFileFromS3 = async (req, res) => {
  const filename = req.query.filename
  var s3 = new AWS.S3()
  var s3Params = {
    Bucket: process.env.AWS_BUCKET,
    Key: 'Tired.pdf',
  }

  // if the file header exists, stream the file to the response
  s3.headObject(s3Params, (err) => {
    if (err && err.code === 'NotFound') {
      console.log('File not found: ' + filename)
    } else {
      s3.getObject(s3Params).createReadStream().pipe(res)
    }
  })
}

export { getFileFromS3, getFileFromS3v3 }

Answer 1

此版本 3 代码有效。感谢 major assist，诀窍是通过管道 data.Body 而不使用任何 fileStream 方法。

import { GetObjectCommand, S3Client } from '@aws-sdk/client-s3'
import dotenv from 'dotenv'

dotenv.config()

const getFileFromS3 = async (req, res) => {
  const key = req.query.filename
  const client = new S3Client({ region: process.env.AWS_REGION })
  const params = {
    Bucket: process.env.AWS_BUCKET,
    Key: key,
  }

  const command = new GetObjectCommand(params)

  try {
    const data = await client.send(command)
    data.Body.pipe(res)
  } catch (error) {
    console.log(error)
  }
}

export { getFileFromS3 }

当从此前端函数调用上面的代码时 returns 文件从 S3 到浏览器。

  const downloadFile = async (filename) => {
    const options = {
      url: `/api/documents/?filename=${filename}`,
      method: 'get',
      responseType: 'blob',
    }

    try {
      const res = await axios(options)
      fileDownload(res.data, filename)
    } catch (error) {
      console.log(error)
    }
  }

将 GetObject (v2) 迁移到 GetObjectCommand (v3) - aws-sdk

Migrate GetObject (v2) to GetObjectCommand (v3) - aws-sdk

amazon-s3

amazon-web-services

express

aws-sdk