在AWS Lambda中导入流(stream)到S3存储桶时,可以使用putObject()方法。以下是一个使用AWS SDK for Node.js的示例代码,该代码可以将流推送到S3。
const AWS = require('aws-sdk');
const s3 = new AWS.S3();
exports.handler = async (event, context, callback) => {
const stream = event.body; // 获取流
const params = {
Bucket: 'YOUR_BUCKET_NAME',
Key: 'YOUR_OBJECT_KEY',
Body: stream
};
s3.putObject(params, function(err, data) {
if (err) console.log(err, err.stack); // 错误处理
else console.log(data); // 成功操作
});
};
在这个示例中,从事件体(event.body)获取流,然后使用putObject()方法将流插入到存储桶中。请替换Bucket和Key,以便将其与您自己的存储桶和对象匹配。