Tengo una función lambda que SQS activa, pero parece que SQS la activó varias veces incluso cuando la operación se realizó correctamente. Aquí hay algo de mi código.

 // handle.ts to handle sqs exports.handler = async function (event, context, callback) { // SQS may invoke with multiple messages for (const message of event.Records) { // make the call to a service runAsyncService(message.body) } // ran all async call all together return callback(null, "succeed") };

usando esos controladores, parece que la solicitud se activa 3 veces (configurable pero alcanza el máximo de reintentos) cada una con una ID de solicitud diferente (que algunos dijeron que indicaba que la solicitud se agotó). Luego tuve este código que soluciona el problema de múltiples activadores.

 // new handle.ts to handle sqs event exports.handler = async function (event, context, callback) { let jobs: any = [] // hold all async call // SQS may invoke with multiple messages for (const message of event.Records) { // make the call to a service jobs.push(runAsyncService(message.body)) } // ran all async call all together return Promise.all(jobs) .then(() => { console.log(`All ${jobs.length} job(s) finished`) return context.succeed('Finished') }) };

como puede ver, usé la función Promise.all() para ejecutar todas las llamadas asíncronas, luego llamé a context.succeed() , usando esto tuvo el efecto secundario, si hay múltiples Registros de sqs, si alguna de las tareas es fallaron todas las promesas fallarán incluso cuando las otras tengan éxito. Llamar context.succeed() dentro del ciclo tampoco es una opción porque también activó la llamada varias veces. La única opción que tenía en mente en este momento es limitar el tamaño del lote a 1, pero no me gusta mucho la idea. También usé getlift/lift para configurar sqs y lambda juntos. ¿Tienen alguna sugerencia para mí? Gracias.