caso de uso
Real-time y escala: tu dominio en FlashRoute — Mundo Real
Caso de uso 5: Industria: Logistica. Nivel: Mid (ownership). 8 lecciones. Streaming GPS, ETAs, SLAs, scaling.
Bienvenido a FlashRoute
Conoce la empresa de última milla, el equipo, tu dominio de operaciones y los datos GPS de 1000 repartidores que llegan cada 5 segundos.
Día 1 -- Pipeline de ETAs en real-time
Lees eventos GPS de Kafka, calculas distancia restante con la fórmula Haversine e implementas estimación de tiempo de llegada para el dashboard de Ana.
Día 2 -- El dashboard de SLAs
Ana necesita saber qué porcentaje de envíos llegan a tiempo. Diseñas la tabla de hechos de cumplimiento y agregas por zona, repartidor y hora.
Día 3 -- Deduplicación GPS con watermarks
Los datos GPS llegan duplicados porque la app reintenta envíos. Implementas deduplicación en streaming con watermarks de Spark para limpiar el stream sin consumir memoria infinita.
Día 3 (tarde) -- Late data y event time vs processing time
Los GPS llegan desordenados cuando los repartidores salen de tuneles o zonas sin cobertura. Entiendes la diferencia crítica entre event time y processing time y como Spark maneja late data.
Día 4 -- BLACK FRIDAY: el pipeline no escala
El volumen se triplica con 3000 repartidores temporales. El consumer lag se dispara, el dashboard se retrasa. Diagnosticas el bottleneck y optimizas en caliente bajo presion de Ana.
Día 5 -- Circuit breaker y documentación
Un GPS defectuoso inunda el stream con 50 eventos/segundo de basura. Implementas un circuit breaker que detecta anomalias y aisla dispositivos problematicos sin afectar al resto del pipeline.
Retrospectiva -- Skills ganadas y preparación MediTrack
Reflexión sobre la semana: qué aprendiste, qué harías diferente, cómo el ownership cambió tu forma de trabajar. Preparación para el siguiente reto: datos de salud en MediTrack.