Real-time Traffic Data Pipeline with NATS JetStream

This code snippet depicts a real-time traffic data processing pipeline built using NATS JetStream. Data originates from messages on the `traffic.light.events` subject, processed through the `myqueue` queue. The pipeline groups data by `traffic_light_id`, maps it to calculate total cars and passengers per traffic light, and finally POSTs the aggregated data to `https://example.com/traffic_data`. Time windows and batch processing are employed for efficiency.