Cognite MQTT Extractor

Dit hulpmiddel maakt verbinding met MQTT-brokers die worden gebruikt in Cognite-omgevingen, abonneert zich op geselecteerde topics en verzamelt berichten in een bepaalde venster of in realtime. Het decodeert payloads met configureerbare formaten zoals JSON, CBOR, Protobuf of platte tekst en geeft gestructureerde records met tijdstempel, topic en gedecodeerde payload-velden. De initiële setup legt de nadruk op herhaalbare ingestie-semantic en afstemming op Cognite Data Platform, zodat teams veldbeschikbaarheid kunnen valideren voor volledige ingestie. Het ondersteunt zowel live streaming als historische replay om payload-ontwikkelingen in de loop van de tijd te vergelijken. De kernworkflow bevat mappings-regels die gedecodeerde payload-velden vertalen naar een canoniek schema, inclusief typecasting, veldherbenaming en omgaan met ontbrekende waarden. Gebruikers kunnen vereiste mappings, optionele aliassen en data-kwaliteitscontroles definiëren. Gevorderde gebruikers kunnen extractie-regels toepassen om berekende velden af te leiden, eenheden om te zetten of tijdstempels naar UTC te normaliseren. Het hulpmiddel kan resultaten exporteren naar Cognite-ingestiepunten of naar platte bestanden voor offline analyse. Voordelen zijn minder handmatig parseren, consistente schema's over apparaten en snellere validatie van data in Cognite-werkomgevingen. Typische use-cases zijn industriële telemetrie, gebouwbeheersystemen en edge-gateways die telemetrie publiceren. Het onderscheidt zich door native ondersteuning voor meerdere payload-formats, topic-gebaseerde filtering en een expliciete mappinglaag gericht op Cognite-schema-compatibiliteit, wat integratierisico vermindert.