Tengo un proceso que en un período de tiempo muy rápido está publicando muchos mensajes SNS que Lambda procesaría. Sin embargo, Lambda lo está procesando uno a la vez. ¿Es una forma de aplicar algo similar a la agrupación larga de SQS?
tengo codigo:
exports.saveLog = async (event) => { console.log('Event : ', event.Records.length); event.Records.forEach(record => { const sql = record.Sns.Message; ...Me gustaría que Lambda reciba un conjunto de mensajes si se publican en un corto período de tiempo. ¿Es posible?
Amazon SNS es esencialmente solo un sistema pub-sub que le permite publicar un solo mensaje que se distribuye a uno o más puntos finales suscritos.
Para procesar varios mensajes en un único proceso descendente, puede agregar una cola de Amazon SQS que recoja los mensajes del tema de SNS y una función de Lambda que recupere los mensajes en lotes de la cola.