Skip to content

Getting Started

El Worker de Reabastecimiento de Datos es un servicio diseñado para recopilar y transformar alertas de reabastecimiento para enviarlas al equipo de Datos. Procesa eventos relacionados con operaciones de reabastecimiento y reposiciones de productos, los enriquece con datos adicionales y los envía a los sistemas de procesamiento de datos correspondientes.

  • Node.js: Entorno de ejecución (v20+)
  • TypeScript: Lenguaje de programación
  • Express: Framework web para el endpoint de verificación de salud
  • Servicios AWS:
    • SQS (Simple Queue Service): Para recibir eventos de reabastecimiento
    • SNS (Simple Notification Service): Para publicar eventos procesados
  • Cron: Para programar la ejecución del worker
  • Zod: Para validación de datos
  • Axios: Para peticiones HTTP a servicios externos

El worker se integra con los siguientes servicios externos:

  1. Product Gateway: Proporciona información de productos

    • Utilizado para obtener detalles de productos por código EAN
  2. Location Manager: Proporciona información de ubicaciones y contenedores

    • Utilizado para obtener detalles de ubicaciones
    • Utilizado para obtener detalles de contenedores
  3. Product Demand: Proporciona información de demanda para productos

    • Utilizado para obtener datos de demanda de productos por código EAN

Este worker forma parte de un ecosistema más amplio de microservicios enfocado en la gestión de inventario y reabastecimiento. El worker:

  1. Consume eventos de los sistemas de inventario y reabastecimiento
  2. Enriquece estos eventos con datos adicionales de varios servicios
  3. Transforma los datos a un formato estandarizado
  4. Publica los datos procesados en tópicos SNS para su consumo por sistemas de procesamiento de datos