如何使一个套接字stream？ imagemagick后连接https响应S3

我一般都是节点和编程，而且我一直在努力…

我想采取一个https响应，调整与graphicsmagick它，并将其发送到我的亚马逊S3桶。

看来，https res是一个IncomingMessage对象（我找不到任何有关信息），而来自graphicsmagick的stdout是一个Socket。

奇怪的是，我可以使用pipe道，并发送这两个到本地path的writeStream，res和stdout创build一个不错的新的resize的图像。

而且我甚至可以将资源发送到S3（使用knox），它可以工作。

但标准输出不想去S3： – /

任何帮助，将不胜感激！

https.get(JSON.parse(queryResponse).data.url,function(res){ var headers = { 'Content-Length': res.headers['content-length'] , 'Content-Type': res.headers['content-type'] } graphicsmagick(res) .resize('50','50') .stream(function (err, stdout, stderr) { req = S3Client.putStream(stdout,'new_resized.jpg', headers, function(err, res){ }) req.end() }) }) 

knox – 连接到S3 – https://github.com/LearnBoost/knox graphicsmagick – 用于image processing – https://github.com/aheckmann/gm

Answer 1

问题出在事实上，亚马逊需要事先知道内容的长度（感谢DarkGlass）

但是，由于我的图像相对较小，我发现caching优先MultiPartUpload。

我的解决scheme

 https.get(JSON.parse(queryResponse).data.url,function(res){ graphicsmagick(res) .resize('50','50') .stream(function (err, stdout, stderr) { ws. = fs.createWriteStream(output) i = [] stdout.on('data',function(data){ i.push(data) }) stdout.on('close',function(){ var image = Buffer.concat(i) var req = S3Client.put("new-file-name",{ 'Content-Length' : image.length ,'Content-Type' : res.headers['content-type'] }) req.on('response',function(res){ //prepare 'response' callback from S3 if (200 == res.statusCode) console.log('it worked') }) req.end(image) //send the content of the file and an end }) }) }) 

Answer 2

您似乎是从原始图像设置Content-Length而不是resize

也许这有帮助

获取stream的内容长度

https://npmjs.org/package/knox-mpu

Answer 3

你不应该在那里做req.end() 。 通过这样做，您将在已经有时间发送图像数据之前将streamclosures到S3。 当所有的图像数据已经发送时，它将自动end 。