基于NATS JetStream的实时交通数据处理流水线

这段代码描述了一个使用NATS JetStream构建的实时交通数据处理流水线。数据源为`traffic.light.events`主题的消息，通过`myqueue`队列进行处理。流水线首先根据`traffic_light_id`对数据进行分组，然后进行映射，计算每个交通灯的车辆总数和乘客总数，最后将结果以POST请求发送到`https://example.com/traffic_data`。使用了时间窗口和批量处理机制，提高了效率。