该数据采集管道负责从每一辆车所搭载的车载 SDV 软件栈中收集电量状态、健康状态与 V2G 功率流向遥测数据,并将其归并整合为覆盖整个车场的统一运营视图。
数据采集层为每一个充电车位维护着一条持久化的 OCPP WebSocket 会话连接,并对当前插枪车辆车载 SDV 软件栈所发出的 ISO 15118 信号级报文进行解码,以亚秒级的采样间隔提取出电量状态、电池组温度、当前功率流向以及故障代码等关键数据。随后由消息代理组件将这些数据分发至各车辆专属的消息主题(Topic)中,使得下游的调度服务与遥测服务能够各自独立订阅所需数据,而无需彼此争抢同一条物理连接。
由于各车辆数据流到达的顺序并不一致,速率也参差不齐,因此状态归并整合服务会在一个短暂的水印窗口内对每辆车的遥测数据进行缓冲,随后依据车场的参考时间源对时钟偏差进行修正,并每隔一秒将修正后的结果合并为一份统一的车场状态快照。这份快照会同时输送给调度引擎的滚动再优化循环,以及面向操作员的运营看板——看板上会实时展示当前接入总负荷、可用 V2G 放电总余量,以及任何正在上报故障的车辆信息。