O pipeline de ingestão que coleta telemetria de estado de carga, estado de saúde e fluxo de potência V2G do stack SDV de bordo de cada veículo, reconciliando tudo em uma visão operacional única para o depósito.
A camada de ingestão mantém uma sessão WebSocket OCPP persistente por vaga e decodifica mensagens ISO 15118 em nível de sinal do stack SDV de bordo do veículo conectado, extraindo estado de carga, temperatura do pack, direção atual do fluxo de potência e códigos de falha em intervalos sub-segundo. Um broker de mensagens distribui isso em tópicos por veículo, para que os serviços de escalonamento e telemetria a jusante se inscrevam independentemente, sem disputar a mesma conexão.
Fluxos individuais de veículos chegam fora de ordem e em taxas desiguais, então o serviço de reconciliação armazena em buffer a telemetria de cada veículo em uma janela curta de marca d'água, corrige o desvio de relógio em relação à fonte de tempo de referência do depósito e mescla o resultado em um único snapshot do estado do depósito a cada segundo. Esse snapshot alimenta tanto o loop de reotimização do motor de escalonamento quanto o painel do operador, mostrando carga total conectada, margem total disponível de descarga V2G e qualquer veículo reportando falha.