Cognite MQTT Extractor

Esta ferramenta conecta-se a brokers MQTT usados em ambientes Cognite, assina tópicos selecionados e coleta mensagens em uma janela definida ou em tempo real. Decodifica payloads usando formatos configuráveis como JSON, CBOR, Protobuf ou texto simples e emite registros estruturados com carimbo de tempo, tópico e campos de payload decodificados. A configuração inicial enfatiza ingestão repetível e alinhamento de esquema com Cognite Data Platform, permitindo que equipes validem a disponibilidade de campos antes da ingestão completa. Suporta streaming ao vivo e replay histórico para comparar a evolução dos payloads ao longo do tempo. O fluxo central inclui regras de mapeamento que transformam campos decodificados em um esquema canônico, incluindo conversão de tipos, renomeação de campos e tratamento de valores ausentes. Usuários podem definir mapeamentos exigidos, aliases opcionais e verificações de qualidade de dados. Usuários avançados podem aplicar regras de extração para derivar campos calculados, realizar conversões de unidades ou normalizar timestamps para UTC. A ferramenta pode exportar resultados para endpoints de ingest Cognite ou para arquivos planos para análise offline. Vantagens: redução do parsing manual, consistência de esquema entre dispositivos e validação de dados mais rápida em espaços Cognite. Casos típicos: telemetria industrial, automação de edifícios e gateways de borda que publicam telemetria. A ferramenta se diferencia pelo suporte nativo a múltiplos formatos de payload, filtragem por tópico e uma camada de mapeamento explícita voltada para compatibilidade com o esquema Cognite, reduzindo riscos de integração.