Pipeline de traitement de données de trafic en temps réel avec NATS JetStream
2025-05-10
Cet extrait de code décrit un pipeline de traitement de données de trafic en temps réel construit à l'aide de NATS JetStream. Les données proviennent de messages sur le sujet `traffic.light.events`, traités via la queue `myqueue`. Le pipeline regroupe les données par `traffic_light_id`, les mappe pour calculer le nombre total de voitures et de passagers par feu de circulation, et enfin envoie les données agrégées par une requête POST à `https://example.com/traffic_data`. Des fenêtres temporelles et le traitement par lots sont utilisés pour l'efficacité.
Lire plus
Développement