使用 lambda 函数通过 S3 存储桶读取数据

Question

我正在尝试通过 lambda 从 s3 存储桶中读取数据，并且该文件是一个 excel 文件 (.xlsx) 但是当我打印流时它是空的。

const xlsx = require('xlsx');
const AWS = require('aws-sdk');
var ss = new AWS.S3();

exports.handler = async (event) => {

 var file = ss.getObject({ Bucket: 'kapoorbck', Key: 'testdata.xlsx' }).createReadStream();
//console.log(file);
   var buffers = [];

  file.on('data', (data) => {
    buffers.push(data);
  });
console.log(buffers);


file.on('end', function () {
    var buffer = Buffer.concat(buffers);
    var workbook = xlsx.read(buffer);
    //var sheet_name_list = workbook.SheetNames;

    console.log(workbook);
});



return{
  statusCode :200,
  body : "Success"
}

}

Answer 1

我认为核心逻辑没有任何问题，除了两件事

1. 您正在尝试同步打印console.log(buffers);。从流中读取它是一个异步操作，因此 console.log 需要位于 data 事件侦听器或 end 事件侦听器中。
2. 第二件事是您的 return 语句，它也在最后，因此它将首先执行，因为它不会等待异步操作完成。您需要将其移动到结束事件侦听器中，以便 lambda 知道何时返回并完成工作。

希望对你有帮助。