Compartilhar via

Processamento de mensagens em uma solução de IoT

Essa visão geral apresenta os principais conceitos em torno do processamento de mensagens enviadas de seus ativos e dispositivos em uma solução típica de IoT do Azure. Cada seção inclui links para conteúdos que fornecem mais detalhes e diretrizes.

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

Diagrama que mostra a arquitetura de alto nível da solução de IoT baseada na periferia, destacando áreas de processamento de mensagens.

No Azure IoT, o processamento de mensagens refere-se a processos como roteamento e enriquecimento de mensagens enviadas por ativos e dispositivos. Esses processos são usados para controlar o fluxo de mensagens por meio da solução de IoT e para adicionar informações adicionais às mensagens.

Rotear mensagens

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

Tipo de ponto de extremidade Descrição
MQTT Para mensagens bidirecionais com agentes MQTT, incluindo o agente interno para as Operações do Azure IoT e a Grade de Eventos.
Kafka Para mensagens bidirecionais com agentes do Kafka, incluindo Hubs de Eventos do Azure.
Data Lake Para carregar dados em contas de armazenamento do Azure Data Lake Gen2.
Microsoft Fabric OneLake Para carregar dados em lakehouses do OneLake do Microsoft Fabric.
Azure Data Explorer Para carregar dados em bancos de dados do Azure Data Explorer.
Armazenamento local Para enviar dados para um volume persistente disponível localmente, opcionalmente configurável com o Armazenamento de Contêineres do Azure habilitado pelo Azure Arc.

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

Para maior segurança nos dados roteados para seus pontos finais, segredos sincronizados na nuvem/borda são usados em pontos finais de fluxo de dados para autenticação.

Embora os fluxos de dados permitem configurar o roteamento na borda, você também pode definir o roteamento na nuvem. Se o 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.

Enriquecer, transformar e processar mensagens

Enriquecimentos e transformações podem ser aplicados aos dados durante o estágio de processamento para executar várias operações. Essas operações podem incluir:

  • Computar novas propriedades: com base nas propriedades existentes na mensagem
  • Renomear propriedades: para padronizar ou esclarecer dados
  • Converter unidades: converter valores em diferentes unidades de medida
  • Padronizar valores: dimensionar valores de propriedade para um intervalo definido pelo usuário
  • Contextualizar dados: adicionar dados de referência a mensagens para aprimoramento e orientação de insights

O registro de esquemas armazena esquemas para mensagens provenientes de seus ativos. Os fluxos de dados usam esses esquemas de mensagem 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 de IoT do Azure, você pode implantar seus próprios aplicativos de borda altamente disponíveis no cluster do Kubernetes. Os aplicativos de borda podem interagir com o corretor MQTT interno para:

  • Use a lógica de processamento de mensagens personalizadas nas mensagens MQTT.
  • Crie uma lógica de aplicativo personalizada para ser executada na borda.
  • Execute modelos de IA do Edge para processamento de dados em tempo real e tomada de decisão na fonte de geração de dados, reduzindo a latência e o uso de largura de banda.

Para saber mais, confira Desenvolvimento de aplicativos altamente disponíveis para o broker MQTT de Operações IoT do Azure.

Outros serviços de nuvem

Você pode usar outros serviços de nuvem para processar mensagens de seus ativos e dispositivos.

Os pontos de extremidade de fluxo de dados no Azure IoT Operations permitem que você se conecte aos serviços de nuvem para enviar e receber dados de seus ativos. Um ponto de extremidade de fluxo de dados é o ponto de conexão para o fluxo de dados.

Para obter mais informações, consulte:

No Hub IoT e no IoT Central, você pode rotear mensagens para outros serviços. Por exemplo, você pode encaminhar mensagens para o Azure Stream Analytics para analisar e processar grandes volumes de dados de streaming ou para o Azure Functions para executar o código em resposta a eventos. O Stream Analytics também está disponível no runtime do Azure IoT Edge, permitindo que ele processe dados na borda e não na nuvem.

Para obter mais informações, consulte:

Conteúdo relacionado

  • Last updated on