Конвейер сбора данных, собирающий телеметрию состояния заряда, состояния здоровья и потока мощности V2G с бортового SDV-стека каждого автомобиля и объединяющий их в единое операционное представление для всего депо.
Уровень сбора данных поддерживает постоянную WebSocket-сессию OCPP для каждого зарядного места и декодирует сигнальные сообщения ISO 15118 от бортового SDV-стека подключенного автомобиля, извлекая заряд, температуру батареи, текущее направление потока мощности и коды неисправностей с интервалом менее секунды. Брокер сообщений распределяет эти данные по темам для каждого автомобиля, чтобы нижестоящие службы планирования и телеметрии подписывались независимо, не конкурируя за одно соединение.
Потоки от отдельных автомобилей поступают неупорядоченно и с неравномерной частотой, поэтому служба согласования буферизует телеметрию каждого автомобиля в коротком окне водяных меток, корректирует рассинхронизацию часов относительно эталонного источника времени депо и каждую секунду объединяет результат в единый снимок состояния депо. Этот снимок питает как цикл переоптимизации планировщика, так и панель оператора, показывающую общую подключенную нагрузку, общий доступный резерв разряда V2G и любой автомобиль, сообщающий о неисправности.