Pipeline de procesamiento de datos de tráfico en tiempo real con NATS JetStream

Este fragmento de código describe un pipeline de procesamiento de datos de tráfico en tiempo real construido con NATS JetStream. Los datos provienen de mensajes en el tema `traffic.light.events`, procesados a través de la cola `myqueue`. El pipeline agrupa los datos por `traffic_light_id`, los mapea para calcular el total de coches y pasajeros por semáforo, y finalmente envía los datos agregados mediante una solicitud POST a `https://example.com/traffic_data`. Se utilizan ventanas de tiempo y procesamiento por lotes para mejorar la eficiencia.