实时数据流处理管道搭建

使用Flink/Kafka等工具构建高吞吐、低延迟的环卫数据流处理管道，覆盖车辆轨迹、垃圾箱状态、作业事件等实时数据。