Processamento de mensagens em uma solução de IoT

O diagrama a seguir demonstra uma visão de alto nível dos componentes numa solução típica de IoT baseada na periferia. Este artigo concentra-se nos componentes de processamento de mensagens de uma solução de IoT baseada em computação periférica.

O diagrama a seguir mostra uma visão de alto nível dos componentes em uma solução típica de IoT baseada em nuvem. Este artigo se concentra nos componentes de processamento de mensagens de uma solução de IoT baseada em nuvem.

Para encaminhar mensagens dos seus ativos para diferentes pontos de extremidade, o Azure IoT Operations usa fluxos de dados . Os pontos de extremidade de destino podem estar na nuvem ou na periferia. A lista de pontos finais de destino disponíveis inclui:

A interface do usuário da Web da experiência de operações fornece um ambiente sem código para criar e executar seus fluxos de dados.

Para segurança melhorada nos dados que são encaminhados para os seus endpoints, segredos sincronizados de nuvem/borda são usados nos endpoints de fluxo de dados para autenticação.

Embora os fluxos de dados permitam configurar o roteamento na borda, você também pode definir o roteamento na nuvem. Se seu fluxo de dados entregar mensagens à Grade de Eventos do Azure, você poderá usar seus recursos de roteamento para determinar para onde enviar as mensagens.

Para saber mais, consulte Processar e rotear dados com fluxos de dados.

Um hub IoT do Azure fornece um ponto de entrada na nuvem para as mensagens de telemetria que seus dispositivos enviam. Em uma solução típica de IoT, essas mensagens são entregues a outros serviços downstream para armazenamento ou análise.

Roteamento do Hub IoT

No hub IoT, você pode configurar o roteamento para entregar mensagens de telemetria para os destinos de sua escolha. Os destinos incluem:

• Contentores de armazenamento
• Filas de Barramento de Serviço
• Tópicos do Service Bus
• Hubs de Eventos

Cada hub IoT tem um destino padrão chamado ponto de extremidade interno. Os serviços downstream podem ligar-se ao ponto de extremidade integrado para receber mensagens do hub IoT.

Para saber mais, consulte Usar o roteamento de mensagens do Hub IoT para enviar mensagens do dispositivo para a nuvem para diferentes pontos de extremidade.

Você pode usar consultas para filtrar as mensagens enviadas para diferentes destinos.

Roteamento do IoT Central

Se estiver a utilizar o Azure IoT Central, pode utilizar a exportação de dados para enviar mensagens de telemetria para outros serviços a jusante. Os destinos incluem:

• Contentores de armazenamento
• Filas de Barramento de Serviço
• Tópicos do Service Bus
• Hubs de Eventos
• Explorador de Dados Azure
• Webhooks (ganchos da web)

Uma configuração de exportação de dados do IoT Central permite filtrar as mensagens enviadas para um destino.

Para saber mais, consulte Exportar dados do IoT Central.

Grelha de Eventos (Event Grid)

O Hub IoT tem integração integrada com a Grade de Eventos do Azure . Um hub IoT pode publicar um evento sempre que receber uma mensagem de telemetria de um dispositivo. Você pode usar a Grade de Eventos para rotear esses eventos para outros serviços.

Para saber mais, consulte Reagir a eventos do Hub IoT usando a Grade de Eventos para acionar ações e Comparar roteamento de mensagens e Grade de Eventos parado Hub IoT.

Enriquecimentos e transformações podem ser aplicados 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

O registo de esquemas armazena esquemas para mensagens provenientes dos seus ativos. Os fluxos de dados usam esses esquemas de mensagens para decodificar mensagens de vários formatos para que possam ser processadas por fluxos de dados.

A interface do usuário da Web de experiência de operações fornece um ambiente sem código para criar e executar as transformações em seus fluxos de dados.

Para saber mais, consulte Enriquecer dados usando fluxos de dados.

Nas Operações IoT do Azure, você pode implantar seus próprios aplicativos de borda altamente disponíveis no cluster do Kubernetes. As aplicações de borda podem interagir com o broker MQTT integrado para:

• Use a lógica de processamento de mensagens personalizada nas mensagens MQTT.
• Crie uma lógica de aplicação personalizada para ser executada na periferia.
• Execute modelos Edge AI para processamento de dados em tempo real e tomada de decisões na origem da geração de dados, reduzindo a latência e o uso de largura de banda.

Para saber mais, veja Desenvolver aplicações altamente disponíveis para o agente MQTT do Azure IoT Operations.

Para simplificar o processamento downstream, convém adicionar dados a mensagens de telemetria ou modificar sua estrutura.

Enriquecimento de mensagens do Hub IoT

Os enriquecimentos de mensagens do Hub IoT permitem adicionar dados às mensagens enviadas pelos seus dispositivos. Pode adicionar:

• Uma cadeia de caracteres estática
• O nome do hub IoT que processa a mensagem
• Informações do dispositivo twin

Para saber mais, consulte Enriquecimentos de mensagens do Hub IoT de mensagens de dispositivo para a nuvem.

Transformações de mensagens do IoT Central

O IoT Central tem duas opções para transformar mensagens de telemetria:

• Use mapeamentos de para transformar telemetria de dispositivos complexos em dados estruturados ao entrar no IoT Central.
• Use transformações para manipular o formato e a estrutura dos dados do dispositivo antes de os exportar para um destino.

Processamento de mensagens do IoT Edge

Um módulo do Azure IoT Edge pode processar telemetria de um sensor ou dispositivo conectado antes de enviá-lo para um hub IoT. Por exemplo, antes de enviar dados para a nuvem, um módulo do IoT Edge pode:

• Filtrar dados
• Dados agregados
• Converter dados
• Executar classificação de imagem na periferia