S3.putObject - gọi lại không bao giờ được gọi là

Question

Tôi đang cố gắng tải hình ảnh lên S3 nhưng khi tôi gọi s3.putObject (params, callback), gọi lại của tôi không bao giờ được gọi và không có lỗi nào được ghi lại.

Dưới đây là các mã có liên quan:

var params = { 
    Key: key, 
    Body: imageData, 
    ContentLength: imageData.byteCount, 
    ContentType: contentType, 
}; 
this.s3.putObject(params, function(err, data) { 
    console.log('here'); 
    if (err) { 
    callback(err); 
    return; 
    } 
    callback(null, key); 
}); 

đâu params là { Key: 'e2f99bf3a321282cc7dfaef69fe8ca62.jpg', Body: {imageData parsed from request using node-multiparty}, ContentLength: 27802, ContentType: 'image/jpeg', }

Tôi đã xác minh rằng this.s3 là hợp lệ và typeof this.s3.putObject là chức năng như mong đợi.

Answer 1

Nếu mã này đang được sử dụng cho một hàm lambda bạn cần phải thêm context.done() trong hàm callback của putObject như vậy:

 s3.putObject(params, function(err, data) { 
      if (err) console.log(err, err.stack); // an error occurred 
      else  console.log(data);   // successful response 
      context.done(); 
     }); 

này buộc thực hiện để chờ cho đến khi gọi lại được lấp đầy trước nó thoát. Để làm việc này, bạn cũng sẽ cần xóa bất kỳ context.succeed hoặc context.done nào khỏi trình xử lý chính nếu bạn có một trình điều khiển đó.

Answer 2

Tôi nhận được chính xác hành vi tương tự với tất cả các quyền IAM và mất một chút thời gian trước khi tôi làm việc đó.

Nếu hàm lambda của bạn chạy bên trong VPC, bạn phải tạo điểm cuối cho S3 như mô tả trong this article from AWS blog.

Nếu bạn muốn xem chi tiết hơn về nơi treo, bạn có thể sử dụng mã sau đây. Thay vì gọi lại, hãy giữ tham chiếu về yêu cầu và về cơ bản quan sát các sự kiện của nó (xem tài liệu của S3.putObject và AWS.Request).

var obj = s3.putObject(params); 
obj.on('validate',    (...args)=>{args.unshift('validate');    console.log(...args);}) 
    .on('build',    (...args)=>{args.unshift('build');    console.log(...args);}) 
    .on('sign',     (...args)=>{args.unshift('sign');     console.log(...args);}) 
    .on('send',     (...args)=>{args.unshift('send');     console.log(...args);}) 
    .on('retry',    (...args)=>{args.unshift('retry');    console.log(...args);}) 
    .on('extractError',   (...args)=>{args.unshift('extractError');   console.log(...args);}) 
    .on('extractData',   (...args)=>{args.unshift('extractData');   console.log(...args);}) 
    .on('success',    (...args)=>{args.unshift('success');    console.log(...args);}) 
    .on('error',    (...args)=>{args.unshift('error');    console.log(...args);}) 
    .on('complete',    (...args)=>{args.unshift('complete');    console.log(...args);}) 
    .on('httpHeaders',   (...args)=>{args.unshift('httpHeaders');   console.log(...args);}) 
    .on('httpData',    (...args)=>{args.unshift('httpData');    console.log(...args);}) 
    .on('httpUploadProgress', (...args)=>{args.unshift('httpUploadProgress'); console.log(...args);}) 
    .on('httpDownloadProgress', (...args)=>{args.unshift('httpDownloadProgress'); console.log(...args);}) 
    .on('httpError',   (...args)=>{args.unshift('httpError');   console.log(...args);}) 
    .on('httpDone',    (...args)=>{args.unshift('httpDone');    console.log(...args);}) 
    .send(); 

Bằng cách đó tôi đã thấy yêu cầu HTTP cơ bản đã cố gắng để đạt được các url công cộng của xô, mà là không thể từ một VPC trừ khi bạn có điểm cuối :).

Đây cũng là một bài đăng về truy cập AWS ressources từ VPC cũng từ AWS blog.