Processar e encaminhar dados com fluxos de dados
Os fluxos de dados permitem conectar várias fontes de dados e executar operações de dados, simplificando a configuração de caminhos de dados para mover, transformar e enriquecer dados. O componente de fluxo de dados faz parte do Azure IoT Operations, que é implantado como uma extensão do Azure Arc. A configuração de um fluxo de dados é feita por meio de CRDs (definições de recursos personalizados) do Kubernetes.
Você pode escrever configurações para vários casos de uso, como:
- Transforme dados e envie-os de volta para o MQTT
- Transforme dados e envie-os para a nuvem
- Envie dados para a nuvem ou borda sem transformação
Os fluxos de dados não estão limitados à região onde a instância de Operações IoT é implantada. Você pode usar fluxos de dados para enviar dados para pontos de extremidade na nuvem em diferentes regiões.
Funcionalidades principais
Aqui estão os principais recursos dos fluxos de dados.
Processamento e encaminhamento de dados
Os fluxos de dados permitem a ingestão, o processamento e o roteamento das mensagens para coletores especificados. Pode especificar:
- Fontes: de onde as mensagens são ingeridas
- Destinos: para onde as mensagens são drenadas
- Transformações (opcional): Configuração para operações de processamento de dados
Capacidades de transformação
As transformações podem ser aplicadas aos dados durante o estágio de processamento para executar várias operações. Estas operações podem incluir:
- Calcular novas propriedades: com base nas propriedades existentes na mensagem
- Renomear propriedades: para padronizar ou esclarecer dados
- Converter unidades: converta valores em diferentes unidades de medida
- Padronizar valores: dimensionar valores de propriedade para um intervalo definido pelo usuário
- Contextualizar dados: adicione dados de referência a mensagens para enriquecimento e gerar insights
Configuração e implementação
A configuração é especificada usando CRDs do Kubernetes. Com base nessa configuração, o operador de fluxo de dados cria instâncias de fluxo de dados para garantir alta disponibilidade e confiabilidade.
Benefícios
- Configuração simplificada: conecte facilmente fontes de dados e destinos.
- Transformações flexíveis: execute uma ampla gama de operações de dados.
- Configuração escalável: use CRDs do Kubernetes para configurações escaláveis e gerenciáveis.
- Alta disponibilidade: o recurso nativo do Kubernetes garante confiabilidade.
Usando fluxos de dados, você pode gerenciar com eficiência seus caminhos de dados. Você pode garantir que os dados sejam enviados, transformados e enriquecidos com precisão para atender às suas necessidades operacionais.
Registro de esquema
O Registro de Esquema, um recurso fornecido pelo Registro de Dispositivo do Azure, é um repositório sincronizado na nuvem e na borda. O registro de esquema armazena as definições de mensagens provenientes de ativos de borda e, em seguida, expõe uma API para acessar esses esquemas na borda. Conectores Southbound, como o conector para OPC UA, podem criar esquemas de mensagem e adicioná-los ao registro do esquema ou os clientes podem carregar esquemas para a interface do usuário da Web da experiência de operações.
Os fluxos de dados usam esquemas de mensagens para transformar a mensagem no formato esperado pelo ponto de extremidade de destino.
Para obter mais informações, consulte Compreender esquemas de mensagem.