Cognite MQTT Extractor

Dieses Tool verbindet sich mit MQTT-Brokern, die in Cognite-basierten Datenumgebungen verwendet werden, abonniert ausgewählte Topics und sammelt Nachrichten in einem definierten Fenster oder in Echtzeit. Es decodiert Payloads mit konfigurierbaren Formaten wie JSON, CBOR, Protobuf oder Klartext und gibt strukturierte Datensätze mit Zeitstempel, Topic und decodierten Payload-Feldern aus. Die anfängliche Einrichtung betont wiederholbare Ingestions-Semantik und Schemaabgleich mit Cognite Data Platform, wodurch Teams die Verfügbarkeit von Feldern vor der vollständigen Ingestion validieren können. Es unterstützt sowohl Live-Streaming als auch historisches Replay, um Payload-Entwicklung über die Zeit zu vergleichen. Kern-Workflow umfasst Mapping-Regeln, die decodierte Payload-Felder in ein kanonisches Schema übersetzen, einschließlich Typkonvertierung, Feldumbenennung und Umgang mit fehlenden Werten. Benutzer können erforderliche Mappings, optionale Aliases und Datenqualitätsprüfungen festlegen. Fortgeschrittene Benutzer können Extraktionsregeln anwenden, um berechnete Felder abzuleiten, Einheiten zu konvertieren oder Zeitstempel auf UTC zu normalisieren. Das Tool kann Ergebnisse an Cognite-Ingestion-Endpunkte oder in Flachdateien für die Offline-Analyse exportieren. Vorteile umfassen weniger manuelle Feldzuordnung, konsistentes Schema über Geräte hinweg und schnellere Validierung der Daten in Cognite-Arbeitsbereichen. Typische Anwendungsfälle sind Industrie-Telemetrie, Gebäudeautomation und Edge-Gateways, die Telemetrie veröffentlichen. Das Tool zeichnet sich durch native Unterstützung mehrerer Payload-Formate, themenbasierte Filterung und eine explizite Mapping-Schicht aus, die auf Cognite-Schema-Kompatibilität abzielt, was Integrationsrisiken reduziert.