Adicionar origem MQTT a um fluxo de eventos (pré-visualização)

Este artigo mostra-lhe como adicionar uma fonte de Transporte de Telemetria por Fila de Mensagens (MQTT) a um fluxo de eventos no Fabric Real-Time Intelligence.

O Protocolo de Transporte de Telemetria para Filas de Mensagens (MQTT) é um protocolo de mensagens leve de publicação/subscrição, concebido para ambientes restritos e amplamente utilizado em aplicações de Internet das Coisas (IoT). O MQTT Connector para Fabric Eventstream permite-lhe ligar-se a qualquer broker MQTT e ingerir mensagens diretamente no Eventstream, possibilitando a transformação e o encaminhamento em tempo real para vários destinos dentro do Fabric para análises e insights.

Pré-requisitos

Antes de começar, você deve preencher os seguintes pré-requisitos:

  • Um espaço de trabalho com capacidade Fabric ou tipo de espaço de trabalho Fabric Trial.
  • Acesso ao espaço de trabalho com funções de Contribuidor ou funções de nível superior.
  • Certifique-se de que o broker MQTT esteja acessível publicamente e não restrito por um firewall ou uma rede virtual. Se residir numa rede protegida, conecte-se a ela usando a injeção virtual de rede do conector Eventstream.

Dependendo do seu cenário, pode também usar uma das seguintes abordagens para transmitir dados MQTT para o Eventstream:

Adicionar conector MQTT

Pode adicionar o conector MQTT ao Eventstream de duas formas:

De um fluxo de eventos

Adicione uma fonte MQTT diretamente a um fluxo de eventos. Esta abordagem funciona melhor quando se quer configurar um fluxo de eventos dedicado para processar e encaminhar dados MQTT.

  1. No Fabric Inteligência em Tempo Real, cria um novo Fluxo de Eventos ou abre um existente.

  2. Selecionar Adicionar fonte na tela.

    Captura de ecrã que mostra a opção Adicionar fonte na tela do eventostream.

Do Hub de Tempo Real

Liga-te a uma fonte MQTT de Real-Time hub e cria um fluxo de dados. Esta abordagem funciona melhor quando pretende descobrir e gerir o seu fluxo de dados MQTT juntamente com outras fontes de streaming.

  1. Em Fabric, acesse o Real-Time hub.

  2. Selecione Adicionar dados e procure por MQTT.

    Captura de ecrã que mostra a opção Adicionar fonte no hub em tempo real.

Configurar conector MQTT

  1. Na página Conectar, selecione Nova conexão.

    Captura de tela que mostra a página Conectar, o link Nova conexão realçado.

    Se houver uma conexão existente com sua fonte MQTT, selecione essa conexão existente.

  2. Para criar uma nova ligação à cloud, introduza a seguinte informação:

    Captura de tela que mostra a seção Configurações de conexão.

    1. URL do Broker MQTT: introduza o URL do seu corretor MQTT. Os protocolos suportados são ssl://, wss://, e tcp://.

      Note

      O código-fonte MQTT suporta ligações MQTT seguras pela Camada de Transporte (TLS) ou pela Camada Segura de Soquetes (SSL) entre o seu corretor MQTT e o Eventstream. As ligações TLS ou SSL só são suportadas se o certificado do servidor for assinado por uma Autoridade Certificadora (CA) incluída na lista de CA de confiança.

    2. Nome da ligação: introduza um nome para a ligação ao MQTT.

    3. Introduza o nome de utilizador e a palavra-passe do seu corretor MQTT.

    4. Selecione Conectar.

  3. Para nome do tópico, introduza o tópico MQTT a que deseja subscrever-se. O conector suporta apenas um único tópico.

  4. Para a versão, selecione V5 ou V3 com base na versão do protocolo do seu corretor MQTT.

Detalhes do fluxo ou da fonte

  1. Na página de Conectar , siga um destes passos consoante se está a usar o Eventstream ou Real-Time hub.

    • Eventstream:

      No painel de detalhes de origem à direita, siga estes passos:

      1. Para o nome da Fonte, selecione o botão Lápis para alterar o nome.

      2. Note que o nome do Eventstream e o nome do Stream são apenas de leitura.

    • Real-Time hub:

      Na seção Detalhes do fluxo à direita, siga estas etapas:

      1. Seleciona o espaço de trabalho do Fabric onde queres criar o event stream.

      2. Para o nome do Eventostream, selecione o botão Pencil e insira um nome para o eventostream.

      3. O valor nome do Stream é gerado automaticamente ao adicionar -stream ao nome do eventstream. Este fluxo aparece na página Todos os fluxos de dados do hub em tempo real quando o assistente termina.

  2. Selecione Seguinte no final da página de Configurar .

Revise e conecte-se

No ecrã Revisão + ligar, reveja o resumo e selecione Adicionar (Eventstream) ou Ligar (Real-Time Hub).

Ver fluxo de eventos atualizado

  1. A fonte MQTT aparece na tua tela de eventstream em modo Editar . Para publicar, selecione Publicar na fita.

    Captura de tela que mostra o editor com o botão Publicar selecionado.

  2. Depois de publicar, o código-fonte está disponível em visualização em direto. Selecione a peça MQTT no diagrama para ver os detalhes.

    Captura de tela que mostra o editor na visualização ao vivo.

Para obter uma lista de todas as fontes suportadas, consulte Adicionar e gerenciar uma fonte de eventos.