Topología de eventos de pedidos

Topología de eventos de pedidos Diagrama de flujo de datos generado por Archify. 01 / Productores 02 / Tránsito 03 / Procesadores 04 / Estado y recuperación 05 / Consumidores API de compras · productor de pedidos · 01 / Productores · equipo comercial API de compras productor de pedidos equipo comercial API de cobros · productor de pagos · 01 / Productores · equipo de pagos API de cobros productor de pagos equipo de pagos orders.v1 · 12 particiones · 02 / Tránsito · clave: order_id orders.v1 12 particiones clave: order_id payments.v2 · 8 particiones · 02 / Tránsito · clave: order_id payments.v2 8 particiones clave: order_id Validar pedido · grupo de entregas · 03 / Procesadores · ordenado Validar pedido grupo de entregas ordenado Enriquecer pago · grupo de analítica · 03 / Procesadores · al menos una vez Enriquecer pago grupo de analítica al menos una vez Estado de pedidos · vista materializada · 04 / Estado y recuperación · idempotente Estado de pedidos vista materializada idempotente events.dlq · eventos dañados · 04 / Estado y recuperación · retención: 7 días events.dlq eventos dañados retención: 7 días Entrega · flujo de envío · 05 / Consumidores · consumidor Entrega flujo de envío consumidor Analítica · datos en tiempo real · 05 / Consumidores · consumidor Analítica datos en tiempo real consumidor Reprocesar · lote aprobado · 05 / Consumidores · control del operador Reprocesar lote aprobado control del operador De guardia · responsable de DLQ · 05 / Consumidores · SRE De guardia responsable de DLQ SRE OrderPlaced esquema v1 PaymentCaptured esquema v2 pedidos ordenados grupo consumidor datos de pago al menos una vez pedido válido idempotente pago enriquecido idempotente pedidos listos modelo de lectura datos del pedido sin datos personales evento inválido mensaje fallido evento dañado mensaje fallido muestra del error restringido reproceso aprobado lote auditado Leyenda datos principales política / datos personales lote asíncrono almacén de datos flujo de datos

Reglas de tránsito

  • • Cada evento y tema tiene un nombre
  • • Las claves de partición conservan el orden de cada pedido
  • • Los grupos consumidores indican quién procesa los eventos

Estado y entrega

  • • Los procesadores escriben en una vista materializada idempotente
  • • Las entregas y la analítica consumen datos distintos
  • • La entrega al menos una vez no debe duplicar efectos del negocio

Responsables de los errores

  • • Los eventos dañados se conservan en un tema de mensajes fallidos
  • • La persona de guardia revisa las muestras antes de reprocesar
  • • El reprocesamiento es autorizado, por lotes y auditable