使用Node.js将二进制数据推送到Amazon S3

我正在尝试拍摄图像,并使用Node.js将其上传到Amazon S3存储区.最后,我想将图像推送到S3,然后可以访问该S3的URL,并在浏览器中查看图像.我使用Curl查询来执行http POST请求,其中图像为主体.

curl -kvX POST –data-binary“@ test.jpg”’http：// localhost：3031 / upload / image’

然后在Node.js端,我这样做：

exports.pushImage = function(req,res) {
    var image = new Buffer(req.body);
    var s3bucket = new AWs.S3();
    s3bucket.createBucket(function() {
        var params = {Bucket: 'My/bucket',Key: 'test.jpg',Body: imagE};
        // Put the object into the bucket.
        s3bucket.putObject(params,function(err) {
            if (err) {
                res.writeHead(403,{'Content-Type':'text/plain'});
                res.write("Error uploading data");
                res.end()
            } else {
                res.writeHead(200,{'Content-Type':'text/plain'});
                res.write("success");
                res.end()
            }
        });
    });
};

我的文件是0个字节,如Amazon S3所示.如何使它能够使用Node.js将二进制文件推送到S3？二进制数据和缓冲区我做错了什么？

更新：

我发现我需要做什么卷曲查询是应该改变的第一件事情.这是工作的：

curl -kvX POST -F foobar=@my_image_name.jpg’http：// localhost：3031 / upload / image’

然后,我添加了一行转换为流.这是工作代码：

exports.pushImage = function(req,res) {
    var image = new Buffer(req.body);
    var s3bucket = new AWs.S3();
    s3bucket.createBucket(function() {
        var bodyStream = fs.createReadStream(req.files.foobar.path);
        var params = {Bucket: 'My/bucket',Body: bodyStream};
        // Put the object into the bucket.
        s3bucket.putObject(params,{'Content-Type':'text/plain'});
                res.write("success");
                res.end()
            }
        });
    });
};

因此,为了将文件上传到API端点(使用Node.js和Express)并将API推送到Amazon S3,首先需要执行POST请求,并填充“files”字段.该文件最终在API端,它所在的位置可能在某个tmp目录中.亚马逊的S3 putObject方法需要一个Stream,因此您需要通过给“fs”模块创建上传文件所在的路径来创建一个读取流.

我不知道这是否是上传数据的正确方式,但它是有效的.有没有人知道有没有办法在请求体内POST二进制数据,并将API发送到S3？我不太了解多部分上传与标准POST到正文之间的区别.

var fs = require('fs');
var bucket_name = 'your-bucket name'; // AwsSum also has the API for this if you need to create the buckets

var img_path = 'path_to_file';
var filename = 'your_new_filename';

// using stat to get the size to set contentLength
fs.stat(img_path,function(err,file_info) {

    var bodyStream = fs.createReadStream( img_path );

    var params = {
        BucketName    : bucket_name,ObjectName    : filename,ContentLength : file_info.size,Body          : bodyStream
    };

    s3.putObject(params,data) {
        if(err) //handle
        var aws_url = 'https://s3.amazonaws.com/' + DEFAULT_BUCKET + '/' + filename;
    });

});