La pipeline di ingestione che raccoglie telemetria sullo stato di carica, sullo stato di salute e sul flusso di potenza V2G dallo stack SDV di bordo di ogni veicolo, riconciliandola in un'unica vista operativa per l'intero deposito.
Lo strato di ingestione mantiene una sessione WebSocket OCPP persistente per stallo e decodifica messaggi ISO 15118 a livello di segnale dallo stack SDV di bordo del veicolo collegato, estraendo stato di carica, temperatura del pacco, direzione attuale del flusso di potenza e codici di guasto a intervalli inferiori al secondo. Un broker di messaggi distribuisce questi dati in topic per veicolo, così i servizi di scheduling e telemetria a valle si iscrivono in modo indipendente senza contendersi la stessa connessione.
I flussi dei singoli veicoli arrivano fuori ordine e a ritmi disomogenei, quindi il servizio di riconciliazione mette in buffer la telemetria di ciascun veicolo in una breve finestra watermark, corregge lo sfasamento dell'orologio rispetto alla fonte di tempo di riferimento del deposito e unisce il risultato in un unico snapshot dello stato del deposito ogni secondo. Tale snapshot alimenta sia il ciclo di riottimizzazione del motore di scheduling sia la dashboard dell'operatore, mostrando il carico totale connesso, il margine totale disponibile di scarica V2G e qualsiasi veicolo che segnali un guasto.