Clasificaciones en tiempo real: arquitectura técnica

La clasificación de tiempo real es un conjunto de servicios que convierte millones de eventos de juego en posiciones actualizables en cientos de milisegundos, manteniendo la honestidad, la auditabilidad y la manejabilidad económica. A continuación, un constructor práctico desde los requisitos hasta la operación.

1) Requisitos y objetivos

Latencia a IU: ≤ 200-300 ms p95 desde la llegada del evento hasta la actualización de la posición.

Precisión: puntuación correcta de «mejores N «/divisiones/tie-breaks cuando la carga y los fallos.

Disponibilidad: ≥ 99. 9% durante el período del torneo; degradación sin pérdida de integridad.

Idempotencia: «exactamente una vez» en el nivel de cobro, «al menos una vez» en el transporte.

Escala: crecimiento horizontal por regiones/divisiones/equipos (Top-K en la carta).

Auditoría: registros inmutables de reglas, eventos, devengos y entregas.

2) Esquema del sistema (nivel de 10.000 pies)

Клиент → Event Ingest → Scoring Engine → Stream Aggregator (Top-K/Top-M) → Write-Optimized Store → Hot Cache/Edge → UI/Comms → Rewards/Claim

Фоново: Snapshotter, Anti-Fraud/RG, Analytics & A/B, Audit/Observability.

3) Recepción de eventos (Event Ingest)

Tareas: protección contra tomas, picos, pérdidas de red.

Idempotencia: cada evento tiene un 'event _ uuid'; verificación «visto/cobrado».

Semántica de entrega: transporte - at-least-once, cuenta de gafas - exactly-once.

Backpressure: colas con lotes dinámicos; cuando hay sobrecarga - priorizar los tours «activos».

Ventanas temporales: permitimos eventos late (por ejemplo, hasta 90 segundos) - enrutamos a la «ventana de recuento».

Tiempo: servidor UTC, en el cliente - sólo visualización local.

4) Puntuación (Scoring Engine)

Principios: reglas versionables, anti-pay-to-win, fácil retroceso.

Versioning: 'rule _ set _ id' + feature-flags per-region/division.

Modelos: multiplier ('Score = round (100log2 (Win/Bet + 1))'), win-based con curva de registro, wager-based (sólo como meta de fondo).

Puntuación «mejor N «: mantenemos la estructura top-N por jugador/día/tour; resumen/mediana por formato.

Excepciones: fondos de bonificación 'coef _ bonus ≤ 0. 5 'o' 0 '; cap per spin/day; cuotas por proveedor.

Tie-break: 1) logro anterior del score final; 2) mayor diversidad; 3) semilla determinista.

5) Agregación Stream y Top K

Objetivo: volver a calcular rápidamente las posiciones sin escanear todo el conjunto.

Charding: 'shard _ id = hash (division_id	region	tournament_id)`; volumen fijo de la parte superior K en la parte superior.
Algoritmos: Min-heap para el árbol superior K, Order-statistics o «cuenta B-tree»; para los comandos - Sum Top-M contribuciones.
Incrementalidad: actualizamos sólo las posiciones cambiantes; suscripciones diff (push player-centric).
Fusión: el top K local en la carta → el top global a través de k-way merge (regular).
Eventos posteriores: un recuento «en la sombra» y un update seguro con versionamiento del estado.

6) Almacenamiento: write vs read

Write-optimized store: registro de valores devengados, estado "best-N', tie-breaks, metadatos (sólo entradas/apdates).

Tienda de lectura optimizada (Query): «vitrinas» desnormalizadas para IU: top 100, «mi posición», «top day/division», contribución al equipo.

Imágenes (Snapshotter): «snapshots» de liderazgo por hora; rollback/replay rápido, informes y auditoría.

Consistencia: eventual para listas amplias, read-your-writes para «mi posición».

7) Caché y Edge

Caché caliente: las últimas posiciones y la puntuación de los jugadores en la bufanda; TTL de 1 a 5 segundos; discapacidad por evento.

Edge-capa/CDN: bloques estáticos, páginas de resultados «fríos», pero no la lógica de acumulación.

Fallback: cuando se degradan - «modo bronce»: actualización de UI cada X segundos + bloque de widgets pesados.

8) Tiempo, ventanas y temporizadores

Tiempo único «verdadero»: UTC en los servicios; Los días en línea en UTC.

Localización: convertir la hora en el cliente (zona horaria del usuario).

Bordes: «ventana suave» de cierre de 1-3 min para lagunas de red (en T&C).

Vamos a la clase de guardia: monitoreo de clock-skew, alertas NTP, medición de deriva.

9) Lucha contra eventos tardíos y duplicados

Eventos Late: mantenemos la «ventana de reconciliación»; conversión local + ajuste «tranquilo» de las posiciones de la cinta de notificaciones.

Tomas: 'event _ uuid' + (player, game, bet, ts) en una ventana estrecha; la revista «seen».

Idempotencia de la acumulación: transacciones «evento → cambio» con estado de applied/rolled_back.

10) Anti-frod y RG (incorporado en pipeline)

Puntuación conductual: intervalos uniformes, ultra velocidad, «sin ruido» - banderas.

Gráfico de vínculos: dispositivos/IP/pagos compartidos → clústeres; colinas de recompensas, verificación manual.

Cuotas y caps: N mejores intentos/día, cuotas de una ranura/proveedor, gafas de la tapa per spin/day.

Fondos de bonificación: coeficientes/excepción.

RG: los puntos sólo se otorgan dentro de límites voluntarios (tiempo/depósitos/pérdidas); recordatorios de interrupciones.

11) Multi-región y tolerancia a fallas

Activo-activo por región: conjuntos regionales + conjuntos mundiales; Enrutamiento por proximidad.

RTO/RPO: RTO <15 min (folback en snapshots), RPO = 0 para acumulaciones (relé idempotente del registro).

Partition-tolerance: en una brecha de red, el liderazgo local, la consolidación posterior y la corrección suave de posiciones.

FX y monedas: si los premios están en diferentes monedas - registramos el momento de conversión, el buffer FX es del 1-3%.

12) Seguridad y privacidad

Datos: minimización (alias, sin PII en el agregador), cifrado «en vuelo» y «en reposo».

Acceso: principio de los privilegios más pequeños, secretos en KMS, auditoría de acceso.

T & C/jurisdicciones: registros de reglas/versiones, geo-bloques, límites de edad.

13) Observabilidad y prácticas de ERE

SLO: UI-nat ≤ 300 ms p95, Claim-time ≤ 10 min p95, aptime ≥ 99. 9%.

Métricas: eventos/sec, proporción de tomas/rechazadas, late-rate, heap-growth top K, lag stream, errores de acumulación, claim-rate.

Treking: end-to-end (ingest → scoring → cache → UI).

Alertas: botón de parada (desactivable experimentos pesados/reducir N mejor), auto-degradación.

Post-mortem: RCA en 24-48 h, action items list, error-budget policy.

14) Rewards & Claim

Recompensa automática: en un evento cerrado - cálculo de posiciones, emisión, recibos.

Ventana Claim: ≤ 72 horas, retrés de entrega, orden de pago determinista.

Transparencia: historial de premios en el perfil: regla, tiempo, cantidad, fuente.

Colinas: para premios raros/valiosos hasta KYC/AML.

15) Experimentos A/B y evolución de los circuitos

Qué probar: N top (10/20), cap per spin (on/off), bono de diversidad (0/50/100), tipo de agregación (suma/mediana).

Aleatorización: por regiones/canales/clústeres - evitamos los flujos.

Guardrails: RTP, quejas/10k, señales RG - no se deterioran.

Migraciones: compatibilidad de esquemas de almacenamiento, escritura doble (dual-write) durante la migración.

16) Patrones de clasificación en tiempo real de UX

Centro de clasificación: regla de victoria, temporizador, cuenta, intentos restantes, siguiente recompensa.

Fiedback vivo: «+ 40 puntos para x3», «quedan 2 intentos de 20», «has subido 3 puestos».

Vitrinas: top 100 general, «mi posición», «top day/divisional», contribución al equipo.

A11y: contraste, números grandes, focus states, doblaje del progreso.

Localización: Dilines/temporizadores en TZ local, multilingüismo.

17) Fallas frecuentes y escenarios de degradación

Error	Síntoma	Acción
Pico de carga en Ingest	Aumento de las colas	Reducción temporal de N de los mejores, priorización de tours activos
Caída del procesador de flujo	Estancamiento del Top K	Feilover de los workers, réplica del registro, exhibición del sueño
late-rate inflado	Ajustes masivos	Aumentar la «ventana suave», resaltar explícitamente los reprogramos en IU
Tomas de eventos	«Puntos dobles»	Más estricta desduplicación, bloque de fuentes sospechosas
Lag caché	«Saltos» de posiciones	Discapacidad por evento, limitación de solicitudes pesadas

18) Checklist de lanzamiento de calificaciones en tiempo real

Reglas/Economía

Fórmula, N mejores, tie break, divisiones
RewardRate, ancho de pago, pagadores, claim ≤ 72 h

Técnica

Idempotent Ingest, Late-window, charding
Stream-Aggregator (топ-K/Top-M), Snapshotter
Hot Cache/Edge, API de salud/estado, botón de parada

Seguridad/RG

Puntuación conductual, gráfico de conexiones, capas/cuotas
Límites de RG, recordatorios, KYC/AML para grandes premios

Datos/A/B

Dashboards: late-rate, tomas, métricas de fairness
Plan de experimentación y guardrails, dual-write en migraciones

UX

Centro de clasificación, micro-fidback, A11y, localización
Reglas breves en 1 pantalla + T&C completos

Una calificación confiable en tiempo real no es un servicio, sino un ecosistema disciplinado: recepción idempotente, puntuación versionable, agregación en streaming de la parte superior de K, caché rápido, imágenes de estado y mecanismos antifraude/RG integrados. Agregue SLO/SLA rigurosos, UX comprensible y verificación de cambios a través de A/B - y obtendrá las tablas de liderazgo en las que los jugadores confían, y el producto obtiene un crecimiento predecible de Retention, Stickiness y LTV.