Adicionar fonte MQTT a um eventstream (versão prévia)

Este artigo mostra como adicionar uma fonte MQTT (Transporte telemétrico de enfileiramento de mensagens) a um fluxo de eventos no Fabric Real-Time Intelligence.

O Protocolo de Telemetria de Enfileiramento de Mensagens (MQTT) é um protocolo leve de mensagens de publicação e assinatura, projetado para ambientes restritos e amplamente utilizado em cenários de Internet das Coisas (IoT). O MQTT Connector for Fabric Eventstream permite que você se conecte a qualquer agente do MQTT e ingera mensagens diretamente no Eventstream, habilitando a transformação em tempo real e o roteamento para vários destinos no Fabric para análise e insights.

Pré-requisitos

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

  • Um workspace com capacidade Fabric ou tipo de workspace Avaliação do Fabric.
  • Acesso ao workspace com Colaborador ou papéis de workspace superiores.
  • Verifique se o agente MQTT é acessível publicamente e não está restrito por um firewall ou uma rede virtual. Se ele residir em uma rede protegida, conecte-se a ela usando a injeção de rede virtual do conector Eventstream.

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

Adicionar conector MQTT

Você pode adicionar o conector MQTT ao Eventstream de duas maneiras:

De um fluxo de eventos

Adicione uma fonte MQTT diretamente a um fluxo de eventos. Essa abordagem funciona melhor quando você deseja configurar um fluxo de eventos dedicado para processar e rotear dados MQTT.

  1. No Fabric Real-Time Intelligence, crie um novo Eventstream ou abra um existente.

  2. Selecione Adicionar origem na tela.

    Captura de tela que mostra a opção Adicionar origem na tela eventstream.

Do Hub em Tempo Real

Conecte-se a uma origem MQTT do Real-Time hub e crie um fluxo de dados. Essa abordagem funciona melhor quando você deseja descobrir e gerenciar seu fluxo de dados MQTT junto com outras fontes de streaming.

  1. No Fabric, acesse o hub em tempo real.

  2. Selecione Adicionar dados e pesquise por MQTT.

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

Configurar conector MQTT

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

    Captura de tela mostrando a página Conectar com o link Nova conexão em destaque.

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

  2. Para criar uma nova conexão de nuvem, insira as seguintes informações:

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

    1. URL do MQTT Broker: insira a URL do seu agente MQTT. Os protocolos com suporte são ssl://, wss://e tcp://.

      Note

      A origem MQTT oferece suporte a conexões MQTT seguras, utilizando TLS (Transport Layer Security) ou SSL (Secure Sockets Layer), entre o seu agente MQTT e o Eventstream. As conexões TLS ou SSL só serão compatíveis se o certificado do servidor for assinado por uma AC (Autoridade de Certificação) incluída na lista de AC confiável.

    2. Nome da conexão: insira um nome para a conexão com o MQTT.

    3. Insira o nome de usuário e a senha do seu agente MQTT.

    4. Selecione Conectar.

  3. Para o nome do tópico, insira o tópico MQTT ao qual assinar. O conector dá suporte apenas a um único tópico.

  4. Para a Versão, selecione V5 ou V3 com base na versão de protocolo do agente MQTT.

Detalhes do fluxo ou da origem

  1. Na página Conectar , siga uma destas etapas com base em se você está usando o Eventstream ou Real-Time hub.

    • Fluxo de eventos:

      No painel Detalhes da origem à direita, siga estas etapas:

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

      2. Observe que o nome do fluxo de eventos e o nome do fluxo são somente leitura.

    • Real-Time hub:

      Na seção Detalhes de streaming à direita, siga estas etapas:

      1. Selecione o workspace do Fabric no qual você deseja criar o fluxo de eventos.

      2. Para nome do Eventstream, selecione o botão Lápis e insira um nome para o Eventstream.

      3. O valor do nome do Stream é gerado automaticamente para você acrescentando -stream ao nome do fluxo de eventos. Esse fluxo aparece na página Todos os fluxos de dados do hub em tempo real quando a execução do assistente é finalizada.

  2. Selecione Avançar na parte inferior da página Configurar .

Examinar e conectar

Na tela Examinar + conectar, examine o resumo e selecione Adicionar (Eventstream) ou Conectar (Real-Time Hub).

Exibir fluxo de eventos atualizado

  1. A origem do MQTT aparece na tela do eventstream no modo Editar. Para publicar, selecione Publicar na faixa de opções.

    Captura de tela mostrando o editor com o botão Publicar escolhido.

  2. Depois de publicar, a origem estará disponível no modo de exibição Live. Selecione o bloco MQTT no diagrama para exibir detalhes.

    Captura de tela mostrando o editor na exibição ao vivo.

Para obter uma lista de todas as fontes com suporte, confira Adicionar e gerenciar uma fonte de eventos.