Echtzeit-Verkehrsdatenpipeline mit NATS JetStream

Dieser Codeausschnitt beschreibt eine Echtzeit-Verkehrsdatenpipeline, die mit NATS JetStream erstellt wurde. Die Daten stammen von Nachrichten zum Thema `traffic.light.events`, die über die Queue `myqueue` verarbeitet werden. Die Pipeline gruppiert die Daten nach `traffic_light_id`, bildet sie ab, um die Gesamtzahl der Autos und Passagiere pro Ampel zu berechnen, und sendet die aggregierten Daten schließlich per POST-Anfrage an `https://example.com/traffic_data`. Zeitfenster und Batchverarbeitung werden zur Effizienzsteigerung eingesetzt.