如何从 Node.js 中的 S3 getObject 获得响应

从S3API执行getObject()时，根据docs，文件的内容位于Body属性中，您可以从示例输出中看到.你应该有如下代码

const aws = require('aws-sdk');
const s3 = new aws.S3(); // Pass in opts to S3 if necessary

var getParams = {
    Bucket: 'abc', // your bucket name,
    Key: 'abc.txt' // path to the object you're looking for
}

s3.getObject(getParams, function(err, data) {
    // Handle any error and exit
    if (err)
        return err;

  // No error happened
  // Convert Body from a Buffer to a String
  let objectData = data.Body.toString('utf-8'); // Use the encoding necessary
});

您可能不需要从data.Body对象创建新的缓冲区，但如果需要，可以使用上面的示例来实现这一点.

@ AWS SDK/Cclipse S3(2021更新)

自从我在2016年写下这个答案以来，亚马逊发布了一个新的JavaScript SDK，@aws-sdk/client-s3.这个新版本改进了原来的getObject()，它总是返回一个promise ，而不是 Select 通过.promise()链接到getObject().除此之外，response.Body不再是Buffer，而是Readable|ReadableStream|Blob中的一个.这会稍微改变response.Data的处理方式.这应该更具性能，因为我们可以对返回的数据进行流式处理，而不是将所有内容都保存在内存中，这样做的代价是，实现起来会更加冗长.

在下面的示例中，response.Body个数据将被流式传输到一个数组中，然后作为字符串返回.这是与我最初的答案相同的例子.或者，response.Body可以使用stream.Readable.pipe()来发送HTTP响应、文件或任何其他类型的stream.Writeable以供进一步使用，这将是获取大型对象时性能更高的方式.

如果你想使用Buffer，就像最初的getObject()响应一样，这可以通过将responseDataChunks包装在Buffer.concat()中而不是使用Array#join()来实现，这在与二进制数据交互时会很有用.注意，由于Array#join()返回一个字符串，responseDataChunks中的每个Buffer实例将隐式调用Buffer.toString()，并将使用默认编码utf8.

const { GetObjectCommand, S3Client } = require('@aws-sdk/client-s3')
const client = new S3Client() // Pass in opts to S3 if necessary

function getObject (Bucket, Key) {
  return new Promise(async (resolve, reject) => {
    const getObjectCommand = new GetObjectCommand({ Bucket, Key })

    try {
      const response = await client.send(getObjectCommand)
  
      // Store all of data chunks returned from the response data stream 
      // into an array then use Array#join() to use the returned contents as a String
      let responseDataChunks = []

      // Handle an error while streaming the response body
      response.Body.once('error', err => reject(err))
  
      // Attach a 'data' listener to add the chunks of data to our array
      // Each chunk is a Buffer instance
      response.Body.on('data', chunk => responseDataChunks.push(chunk))
  
      // Once the stream has no more data, join the chunks into a string and return the string
      response.Body.once('end', () => resolve(responseDataChunks.join('')))
    } catch (err) {
      // Handle the error or throw
      return reject(err)
    } 
  })
}

@aws-sdk/client-s3 Documentation Links

• GetObjectCommand
• GetObjectCommandInput
• GetObjectCommandOutput