node.js - 使用 Node fs 从 aws s3 存储桶读取文件

标签 node.js amazon-web-services amazon-s3 fs

我正在尝试使用

读取 aws s3 存储桶中的文件
fs.readFile(file, function (err, contents) {
  var myLines = contents.Body.toString().split('\n')
})

我已经能够使用 Node aws-sdk 下载和上传文件,但我不知道如何简单地读取它并解析其内容。

这是我如何从 s3 读取文件的示例:

var s3 = new AWS.S3();
var params = {Bucket: 'myBucket', Key: 'myKey.csv'}
var s3file = s3.getObject(params)

最佳答案

您有几个选择。您可以将回调作为第二个参数包含在内,将使用任何错误消息和对象调用该回调。这个example直接来自 AWS 文档:

s3.getObject(params, function(err, data) {
  if (err) console.log(err, err.stack); // an error occurred
  else     console.log(data);           // successful response
});

或者,您可以将输出转换为流。还有一个example在 AWS 文档中:

var s3 = new AWS.S3({apiVersion: '2006-03-01'});
var params = {Bucket: 'myBucket', Key: 'myImageFile.jpg'};
var file = require('fs').createWriteStream('/path/to/file.jpg');
s3.getObject(params).createReadStream().pipe(file);

关于node.js - 使用 Node fs 从 aws s3 存储桶读取文件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27299139/

相关文章:

symfony - 尝试使用 gaufrette 上传到 S3 时出错

linux - 无法理解为什么 Node 进程在树莓派 2 上崩溃

ios - [错误] : unsupported URL in AWS

node.js - AWS lambda 与 mongoose 到 Atlas - MongoNetworkError

amazon-web-services - kubernetes LoadBalancer服务

amazon-s3 - boto s3 连接 - 使用什么端口?

python - 使用 boto3 的 StreamingBody.iter_lines() 迭代 S3 中的文件是否算作每行的 GET 请求?

javascript - 控制台错误 NodeJS 配置

node.js - ExpressJS 中的 Sequelize 交易未执行

node.js - 我如何在node.js (adonis) 中定义表的索引