NATS JetStream을 사용한 실시간 교통 데이터 처리 파이프라인

이 코드 스니펫은 NATS JetStream을 사용하여 구축된 실시간 교통 데이터 처리 파이프라인을 보여줍니다. 데이터는 `traffic.light_events` 토픽의 메시지에서 가져오고 `myqueue` 큐에서 처리됩니다. 파이프라인은 `traffic_light_id`로 데이터를 그룹화하고 각 신호등의 총 차량 수와 승객 수를 계산하기 위해 매핑하고 마지막으로 집계된 데이터를 `https://example.com/traffic_data`로 POST 요청을 통해 전송합니다. 효율성을 높이기 위해 시간 윈도우와 배치 처리가 사용됩니다.