这是我的lambda处理程序,我使用各种AWS服务.
exports.handler = function(event,context){
var body = event;
var isValidBody = validate.doValidation(body);
var s3DetailsObj = {
eTag: body.s3Details.eTag,
location: body.s3Details.location,
key: body.s3Details.key,
bucket: body.s3Details.bucket
}
var s3DeletionErrorObject = {
status : "SERVER_ERROR",
sourceUid : body.sourceUid,
s3Details : s3DetailsObj
};
if(isValidBody.status){
console.log("Request validation successfull");
async.waterfall([
function downloadFromS3(uploadToGlacier){
//console.log('KEY ====== :',body.s3Details.key);
var params = {
Bucket: 'imagebucketgsk',
Key: body.s3Details.key
};
s3.getObject(params,function(error, response){
//console.log("Into S3 get object");
if(!error){
//console.log('Repsonse = ', response.Body);
uploadToGlacier(null,response);
}else{
//console.error("S3 get error : ", error);
context.succeed(s3DeletionErrorObject);
}
}); …Run Code Online (Sandbox Code Playgroud)