如何下载图像并将 S3 放入 lambda nodejs

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)