S3.putObject - wywołanie zwrotne nigdy nie jest wywoływane

Question

Próbuję przesłać obraz do S3, ale kiedy zadzwonię do s3.putObject (params, callback), mój callback nigdy nie zostanie wywołany i żadne błędy nie są rejestrowane.

Oto odpowiedni kod:

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); 
}); 

Gdzie params jest { Key: 'e2f99bf3a321282cc7dfaef69fe8ca62.jpg', Body: {imageData parsed from request using node-multiparty}, ContentLength: 27802, ContentType: 'image/jpeg', }

I sprawdzeniu, że this.s3 jest ważna i typeof this.s3.putObject jest funkcja, jak oczekiwano.

Answer 1

Jeśli kod ten jest używany dla funkcji lambda trzeba dodać context.done() wewnątrz funkcji zwrotnej na putObject jest tak:

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

Wymusza wykonanie czekać aż zwrotna jest wypełniona przed to wychodzi. Aby to działało, musisz usunąć również context.succeed lub context.done z głównej procedury obsługi, jeśli ją masz.

Answer 2

Mam dokładnie to samo zachowanie z wszystkimi prawami IAM i straciłem trochę czasu, zanim dostałem go do pracy.

Jeśli twoja funkcja lambda działa wewnątrz VPC, musisz utworzyć punkt końcowy dla S3 zgodnie z opisem w this article from AWS blog.

Jeśli chcesz zobaczyć więcej szczegółów, gdzie się zawiesza, możesz użyć następującego kodu. Zamiast podawać wywołanie zwrotne, zachowaj odwołanie na żądanie i zasadniczo obserwuj jego zdarzenia (patrz dokumentacja: S3.putObject i 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(); 

Robiąc tak muszę zobaczyć żądania HTTP bazowy starał się dotrzeć do publiczne adresy wiadra, co nie jest możliwe z VPC chyba że masz punkt końcowy :).

Oto kolejny wpis dotyczący dostępu do zasobów AWS z VPC również z AWS blog.