Cognite MQTT Extractor

Esta herramienta se conecta a brokers MQTT usados en entornos Cognite, se suscribe a topics seleccionados y recolecta mensajes en una ventana definida o en tiempo real. Decodifica payloads utilizando formatos configurables como JSON, CBOR, Protobuf o texto plano y emite registros estructurados con marca de tiempo, topic y campos de payload decodificados. La configuración inicial enfatiza la ingesta repetible y el alineamiento con el esquema de Cognite Data Platform, permitiendo a los equipos validar la disponibilidad de campos antes de la ingestión completa. Soporta tanto streaming en vivo como reproducción histórica para comparar la evolución de payloads a lo largo del tiempo. El flujo principal incluye reglas de mapping que traducen campos decodificados a un esquema canónico, incluyendo conversión de tipos, renombramiento de campos y manejo de valores ausentes. Los usuarios pueden especificar mappings obligatorios, alias opcionales y controles de calidad de datos. Usuarios avanzados pueden aplicar reglas de extracción para derivar campos calculados, convertir unidades o normalizar timestamps a UTC. La herramienta puede exportar resultados a endpoints de ingest Cognite o a archivos planos para análisis fuera de línea. Ventajas: menor parsing manual, esquema consistente entre dispositivos y validación de datos más rápida en espacios Cognite. Casos típicos: telemetría industrial, automatización de edificios y gateways edge que publican telemetría. La herramienta se destaca por soporte nativo de múltiples formatos de payload, filtrado por topic y una capa de mapping explícita orientada a la compatibilidad con el esquema Cognite, reduciendo riesgos de integración.