Cognite MQTT Extractor

Cet outil se connecte à des brokers MQTT utilisés dans des environnements Cognite, s’abonne à des topics sélectionnés et collecte les messages dans une fenêtre définie ou en temps réel. Il décode les payloads en utilisant des formats configurables tels que JSON, CBOR, Protobuf ou texte brut, et émet des enregistrements structurés avec horodatage, topic et champs payload décodés. La configuration initiale met l’accent sur des ingestions répétables et un alignement du schéma avec Cognite Data Platform, permettant aux équipes de valider la disponibilité des champs avant l’ingestion complète. Il prend en charge le streaming en direct et le replay historique pour comparer l’évolution des payloads dans le temps. Le flux principal inclut des règles de mapping qui traduisent les champs décodés en un schéma canonique, comprenant le cast des types, le renommage des champs et la gestion des valeurs manquantes. Les utilisateurs peuvent spécifier des mappings obligatoires, des alias optionnels et des contrôles de qualité des données. Les utilisateurs avancés peuvent appliquer des règles d’extraction pour dériver des champs calculés, effectuer des conversions d’unités ou normaliser les horodatages en UTC. L’outil peut exporter les résultats vers les endpoints d’ingestion Cognite ou vers des fichiers plats pour l’analyse hors ligne. Avantages: réduction du parsing manuel, schéma cohérent entre les appareils et validation rapide des données dans les espaces Cognite. Cas d’usage typiques: télémétrie industrielle, automatisation des bâtiments et passerelles edge diffusant de la télémétrie. L’outil se distingue par le support natif de multiples formats de payload, le filtrage par sujet et une couche de mapping explicite orientée compatibilité Cognite, réduisant les risques d’intégration.