Events

Este documento proporciona una visión general de las colas Amazon SQS y eventos SNS utilizados en el Worker de Sugerencias de Reabastecimiento.

Visión General

El worker procesa eventos de transacciones de inventario desde una cola Amazon SQS para actualizar sugerencias de reabastecimiento. Sigue una arquitectura basada en mensajes donde los cambios de inventario desencadenan actualizaciones en las alertas de reabastecimiento.

SQS

Cola de Sugerencias de Reabastecimiento

Esta es la cola principal de la que el worker consume mensajes.

Nombre de Cola: restocking-suggestions-queue

Configuración de URL:

• Producción: Configurado a través de la variable de entorno QUEUE_RESTOCKING_SUGGESTIONS_URL
• Staging: Configurado a través de la variable de entorno QUEUE_RESTOCKING_SUGGESTIONS_URL con endpoint de staging

Propósito: Recibe eventos de transacciones de inventario que necesitan ser procesados para actualizar sugerencias de reabastecimiento

Formato de Mensaje:

interface InventoryTransactionMessage {
  type: string;
  data: {
    entryId: string;
    transactionId: string;
    productId: string;
    productEan: string;
    locationId: string;
    locationType: LocationType;
    containerId?: string;
    stock: number;
    description: string;
    transactionQuantity: number;
    timestamp: string;
  };
  context: {
    country: string;
    warehouse: string;
  };
}

Procesamiento: Los mensajes se reciben en lotes (hasta 10 a la vez) y se procesan secuencialmente

Tiempo de Visibilidad: 30 segundos

Manejo de Errores:

• Los mensajes que causan errores irrecuperables permanecen en la cola
• Los mensajes con errores de negocio conocidos (por ejemplo, formato inválido, reabastecimiento no encontrado) son eliminados de la cola