【发布时间】:2015-10-20 23:30:52
【问题描述】:
在完成创建缩略图的 AWS Lambda 教程后,我决定尝试调整代码以检查文件是 jpg 还是 csv 文件,以及是否只是将其移动到新存储桶中。我从我的代码中删除的唯一东西是 cmets 和 async.waterfall 中可以调整图像大小的函数。但是,每当我测试或运行这个新代码时,我都会得到“在完成请求之前退出进程”并且该函数无法正确传输文件。代码如下:
var async = require('async');
var AWS = require('aws-sdk');
var gm = require('gm')
.subClass({ imageMagick: true }); // Enable ImageMagick integration.
var util = require('util');
var s3 = new AWS.S3();
exports.handler = function(event, context) {
console.log("Reading options from event:\n", util.inspect(event, {depth: 5}));
var srcBucket = event.Records[0].s3.bucket.name;
var srcKey =
decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g, " "));
var dstBucket = 'datacollectionbucket';
var dstKey = srcKey;
if (srcBucket == dstBucket) {
console.error("Destination bucket must not match source bucket.");
return;
}
var typeMatch = srcKey.match(/\.([^.]*)$/);
if (!typeMatch) {
console.error('unable to infer file type for key ' + srcKey);
return;
}
var imageType = typeMatch[1];
if (imageType != "jpg" && imageType != "csv") {
console.log('skipping unrecognized file ' + srcKey);
return;
}
async.waterfall([
function download(next) {
s3.getObject({
Bucket: srcBucket,
Key: srcKey
},
next);
function upload(contentType, data, next) {
s3.putObject({
Bucket: dstBucket,
Key: dstKey,
Body: data,
ContentType: contentType
},
next);
}
], function (err) {
if (err) {
console.error(
'Unable to resize ' + srcBucket + '/' + srcKey +
' and upload to ' + dstBucket + '/' + dstKey +
' due to an error: ' + err
);
} else {
console.log(
'Successfully classified ' + srcBucket + '/' + srcKey +
' and uploaded to ' + dstBucket + '/' + dstKey
);
}
context.done();
}
);
};
谢谢大家
【问题讨论】:
-
您在日志中得到了什么?您有很多
console.log调用,其中有多少出现在您的日志文件中?代码在退出前走了多远? -
我的 console.log 调用都没有出现,它只是告诉我进程在完成请求之前退出
-
好吧,那么脚本在您第一次调用
console.log之前就退出了。您还在将相同的依赖项捆绑到 zip 文件中(例如 async 和 utils)吗? -
是的,我有正确的依赖关系和一切。我不知道你是否熟悉原始代码,但这只是亚马逊为“创建缩略图”教程提供的代码的编辑,有两个变量(我的编辑没有调用)和一个图像调整大小功能已删除。但是,当我重新添加图像大小调整功能时,“进程退出”结果仍然出现。
标签: node.js amazon-web-services aws-lambda