Events

El Container Killer Worker utiliza Amazon Simple Queue Service (SQS) y Amazon Simple Notification Service (SNS) para implementar un sistema de procesamiento de eventos basado en el patrón de mensajería asíncrona. Este enfoque permite un desacoplamiento entre los servicios que generan eventos (productores) y los servicios que los procesan (consumidores).

SQS

Cola: container-killer-queue

URL de Producción

https://sqs.us-east-1.amazonaws.com/849786826922/container-killer-queue

URL de Staging

https://sqs.us-east-2.amazonaws.com/529305108461/container-killer-queue

Propósito

Almacenar los eventos de transacción de salida para su procesamiento por el Container Killer Worker.

Procesamiento

El worker consulta esta cola periódicamente según la configuración del cron job, procesando hasta 10 mensajes en cada ejecución. Los mensajes se eliminan de la cola solo después de ser procesados correctamente.

Flujo de Eventos

1. El servicio de inventario publica un evento OutputTransaction en el tema SNS cuando se produce una transacción de salida.
2. El tema SNS entrega el evento a la cola SQS suscrita (container-killer-queue).
3. El Container Killer Worker, en su ejecución programada, consulta la cola SQS y procesa los mensajes.
4. Para cada mensaje, el worker verifica si el contenedor está vacío y, en caso afirmativo, lo elimina.
5. Después del procesamiento exitoso, el mensaje se elimina de la cola.

Este flujo asíncrono permite que el sistema de inventario y el Container Killer Worker operen de manera independiente, mejorando la resiliencia y la escalabilidad del sistema.