La spina dorsale di una piattaforma di telemetria industriale: riceve, decodifica e archivia le trasmissioni di localizzatori e computer di bordo installati sulle macchine pesanti, ed espone tutto tramite API alle applicazioni embedded e al portale del cliente. La base dati supera i 700 milioni di record di telemetria.
La sfida
Una macchina pesante lavora lontano da qualsiasi ufficio — in cantiere, in miniera, in impianto industriale, nei campi. Il dato che interessa al responsabile (ore motore, consumi, posizione, velocità, guasti, uso reale del mezzo) nasce chiuso nell'hardware di ciascun costruttore, su bus proprietari, e storicamente arrivava al responsabile solo dopo che il problema era già costato disponibilità. E non è un dato che arriva a ritmo civile: centinaia di mezzi trasmettono di continuo, 24 ore su 24, su connessione mobile instabile, con protocolli binari diversi a seconda del localizzatore installato.
La soluzione
Catus è il nucleo di questa piattaforma. Un gateway TCP dedicato accoglie le connessioni dei localizzatori direttamente su socket, decodifica il protocollo del costruttore e consegna la trasmissione a una coda di elaborazione — il che consente di assorbire i picchi senza perdere dati e senza trascinare giù il resto del sistema. Sopra questo flusso grezzo si trova il modello di dominio, con oltre 220 entità, che trasforma le trasmissioni in informazione utile: stato del mezzo, letture dei sensori, dati CAN Bus, eventi di forza G, ingressi e uscite dai recinti virtuali, rifornimenti, turni e rilevazione della produttività. Il backoffice interno si occupa di ciò che il cliente non vede: anagrafica e configurazione di mezzi, dispositivi, SIM, sensori, periferiche e telecamere, oltre alla diagnostica remota di ogni terminale sul campo. E un'API con 25 endpoint serve esclusivamente l'applicazione embedded sulle macchine, inclusa la sincronizzazione offline e l'aggiornamento remoto dell'app a blocchi — necessario perché sul campo la connessione raramente regge un file intero. Completa la piattaforma un servizio di job pianificati, con 22 routine periodiche, che genera allarmi, consolida report, consuma un topic Kafka per l'integrazione con un partner esterno e monitora perfino il costo della propria infrastruttura AWS.
Risultati
Oltre 700 milioni di record di telemetria accumulati, con circa 2.200 mezzi e 1.100 dispositivi tracciati per più di 250 aziende. L'intera piattaforma gira in container su Amazon ECS, con quattro servizi indipendenti pubblicati tramite pipeline automatizzata.