Proyecto corporativo · Presentado sin referencias a la empresa: solo arquitectura y decisiones.
Workers multi-tenant de calificación, límites y liquidación en vivo
Un juego finalizado se califica, las apuestas se liquidan, se agrupan por tenant y se aplican al libro.
Haz clic en un paso para saltar a él. Haz clic en un componente para ver detalles.
Motor multi-tenant de back-office y liquidación para el producto en vivo de un operador de apuestas deportivas en línea. Califica apuestas live simples y parlays al finalizar los juegos, publica la contabilidad en flujos Kafka por tenant, audita la integridad de las cuotas y sirve configuración de límites, reportes y una UI administrativa en Blazor.
Las apuestas en vivo generaban un alto volumen de apuestas efímeras que debían calificarse exactamente como en el libro heredado, sin doble liquidación, entre varios tenants y con estricta corrección financiera. El enfoque heredado era un flujo de calificación único y fuertemente acoplado, sin reintentos ni dead-letter y con poca visibilidad de discrepancias.
01
La calificación debe ser atómica con la actualización de saldos, por lo que la cola vive en el mismo almacén transaccional que las apuestas. Kafka se usa solo tras la liquidación para distribuir resultados a los tenants, donde basta entrega al menos una vez con consumidores idempotentes.
02
Los mensajes fallidos salen de la ruta principal para que un mensaje venenoso no bloquee una partición. El backoff se aplica en el tópico de reintento y los fallos permanentes se comunican a operadores con contexto.
03
Los mensajes de una sola apuesta saturaban el broker en picos. Agrupar 50 apuestas por mensaje y por tenant preservó el orden por tenant y multiplicó el rendimiento.
04
Los handlers devuelven una disposición explícita (confirmar, reintentar, dead-letter). Los errores permanentes de datos se envían a dead-letter y se confirman, los de infraestructura se reintentan y un endpoint de salud expone la última marca de éxito para que el monitoreo decida reinicios.
05
Agregar apuestas liquidadas bajo demanda era demasiado lento. Workers programados recalculan una ventana móvil para absorber calificaciones tardías, de modo que la API de reportes sirve tablas de hechos indexadas en segundos.
06
Las capas de dominio, aplicación, infraestructura y API se registran mediante métodos de extensión y las operaciones de negocio devuelven valores Result en lugar de excepciones, manteniendo explícito el mapeo de errores y simples las pruebas unitarias.