Cognite MQTT Extractor

Questo strumento si collega ai broker MQTT utilizzati in ambienti Cognite, si iscrive a topic selezionati e raccoglie messaggi in una finestra definita o in tempo reale. Decodifica i payload utilizzando formati configurabili come JSON, CBOR, Protobuf o testo semplice e genera record strutturati con timestamp, topic e campi payload decodificati. L’installazione iniziale enfatizza ingestione ripetibile e allineamento dello schema con Cognite Data Platform, permettendo ai team di validare la disponibilità dei campi prima dell’ingestione completa. Supporta sia lo streaming live sia il replay storico per confrontare l’evoluzione dei payload nel tempo. Il flusso principale comprende regole di mapping che traducono i campi decodificati in uno schema canonico, inclusa la conversione di tipi, la rinomina di campi e la gestione dei valori mancanti. Gli utenti possono specificare mappature richieste, alias opzionali e controlli di qualità dei dati. Gli utenti avanzati possono applicare regole di estrazione per derivare campi calcolati, eseguire conversioni di unità o normalizzare i timestamp in UTC. Lo strumento può esportare i risultati verso endpoint di ingestion Cognite o verso file flat per analisi offline. Vantaggi: riduzione del parsing manuale, coerenza dello schema tra dispositivi e convalida dati più rapida negli ambienti Cognite. Casi d’uso tipici: telemetria industriale, automazione degli edifici e gateway edge che pubblicano telemetria. Lo strumento si distingue per supporto nativo di molteplici formati payload, filtraggio per topic e un livello di mapping esplicito orientato alla compatibilità con lo schema Cognite, riducendo i rischi di integrazione.