kai*_*ita 2 lambda amazon-s3 node.js
'use strict';
var https = require('http');
var aws = require('aws-sdk');
var fs = require('fs');
aws.config.update({
accessKeyId: 'id',
secretAccessKey: 'key',
region: 'ap-northeast-1'
});
var s3bucket = new aws.S3();
var bucketName = "bukcetName"
exports.handler = (event, context, callback) => {
https.get("URL.jpg", function(res, body){
body = new Buffer(res.body, 'binary');
var params = {
Bucket:bucketName,
Key: "testLambda",
Body: body,
ACL: 'public-read'
};
s3bucket.upload(params, function(err, data) {
context.done(null, 'Finished UploadObjectOnS3');
});
});
};
Run Code Online (Sandbox Code Playgroud)
APIGateway ---> lambda
我想从 lambda 中的 URL 下载,并且该内容放入 S3。
我无法从 URL 获取二进制数据,但我可以将任何数据放入 S3 中的任何目录,谢谢帮助。
小智 5
我对您的代码进行了一些更改以使其更好地工作。
- 你不需要'fs'。
- 正确的方法是“putObject”而不是“upload”。
谢谢!
'use strict';
var AWS = require('aws-sdk');
var s3 = new AWS.S3();
var http = require('http');
aws.config.update({
accessKeyId: 'id',
secretAccessKey: 'key',
region: 'ap-northeast-1'
});
var s3bucket = new AWS.S3();
var bucketName = "bukcetName";
exports.handler = (event, context, callback) => {
http.get("URL.jpg", function(res){
var imageData = '';
res.setEncoding('binary');
res.on('data', function(chunk){
imageData += chunk;
});
res.on('end', function(){
var params = {
Bucket: bucketName,
Key: "testLambda",
Body: new Buffer(imageData, 'binary'),
ACL: 'public-read'
};
s3.putObject(params, function(err, data) {
if (err) console.log(err, err.stack);
else console.log(data);
context.done(null, 'Finished UploadObjectOnS3');
});
});
});
};
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
2842 次 |
| 最近记录: |