Compartilhar via


Adicione um endpoint personalizado ou uma origem de aplicativo personalizada a um fluxo de eventos.

Se quiser conectar seu próprio aplicativo a um eventstream, você poderá adicionar um ponto de extremidade personalizado ou um aplicativo personalizado como origem. Em seguida, você pode enviar eventos em tempo real para o eventstream a partir do seu próprio aplicativo, utilizando o endpoint de conexão disponibilizado no endpoint ou aplicativo personalizado. Além disso, com o protocolo do Apache Kafka disponível como uma opção para pontos de extremidade personalizados ou aplicativos personalizados, você poderá enviar eventos em tempo real usando o protocolo do Apache Kafka.

Este artigo mostra como adicionar uma fonte de ponto de extremidade personalizada ou uma fonte de aplicativo personalizada a um fluxo de eventos no Microsoft Fabric.

Pré-requisitos

  • Acesso ao workspace em que o fluxo de eventos está localizado. O workspace deve estar na capacidade do Fabric ou no modo de avaliação.

  • Colaborador ou permissões superiores para editar o stream de eventos e adicionar um endpoint personalizado como fonte.

Permissões para autenticação do Microsoft Entra

Se você quiser usar a autenticação do Microsoft Entra para conectar seu aplicativo, precisará de permissões membro ou superior.

É necessário também certificar-se de que a identidade gerenciada do ponto de extremidade personalizado possui as permissões necessárias. Defina as configurações no portal de administração:

  1. No canto superior direito, selecione Configurações (ícone de engrenagem).

  2. Em Governança e insights, selecione o portal de administração.

    Captura de tela que mostra o link do portal de administração na seção para governança e insights dentro das configurações.

  3. Ative a seguinte configuração de locatário para permitir à entidade de serviço o acesso às APIs do Fabric para criar workspaces, conexões ou pipelines de implantação:

    1. Na página Configurações do Locatário, na seção Configurações do Desenvolvedor, expanda a opção Serviços principais podem usar APIs do Fabric.
    2. Defina a alternância como Habilitado.
    3. Para Aplicar em, selecione Toda a organização.
    4. Selecione Aplicar.

    Captura de tela que mostra as configurações do desenvolvedor.

  4. Habilite essa opção para acessar todas as outras APIs (habilitadas por padrão para novos locatários):

    1. Ainda na página configurações do inquilino, expanda a opção Permitir que principais de serviço criem e usem perfis.
    2. Defina a alternância como Habilitado.
    3. Para Aplicar em, selecione Toda a organização.
    4. Selecione Aplicar.

Adicionar dados do ponto de extremidade personalizado como uma origem

  1. Para adicionar uma origem de ponto de extremidade personalizada, na página de introdução, selecione Usar ponto de extremidade personalizado. Ou, então, se você já tiver um eventstream publicado e quiser adicionar dados de um ponto de extremidade personalizado como uma origem, mude para o modo de edição. Na faixa de opções, selecione Adicionar origem>Ponto de extremidade personalizado.

    Captura de tela da opção de usar um ponto de extremidade personalizado.

  2. Na caixa de diálogo Ponto de extremidade personalizado, insira um nome para a origem personalizada em Nome da origem e, a seguir, selecione Adicionar.

    Captura de tela da caixa de diálogo para adicionar um endpoint personalizado.

  3. Após ser criada, a origem de ponto de extremidade personalizada será adicionada ao seu fluxo de eventos na tela do modo de edição. Para implementar os dados recém-adicionados a partir da origem de aplicativo personalizada, selecione Publicar.

    Captura de tela mostrando o eventstream no modo de edição, com o botão Publicar em destaque.

Observação

Um fluxo de eventos pode dar suporte a até 11 origens e destinos combinados somente quando você estiver usando os seguintes tipos:

  • Fonte: ponto de extremidade personalizado.
  • Destinos: Endpoint personalizado e eventhouse com ingestão direta.

As fontes ou destinos não incluídos na lista anterior e os destinos não acrescentados ao fluxo padrão não contam para esse limite.

Adicionar dados do ponto de extremidade personalizado como uma origem

  1. Para adicionar uma origem de ponto de extremidade personalizada, na página de introdução, selecione Usar ponto de extremidade personalizado. Ou, então, se você já tiver um eventstream publicado e quiser adicionar dados de um ponto de extremidade personalizado como uma origem, mude para o modo de edição. Na faixa de opções, selecione Adicionar origem>Ponto de extremidade personalizado.

    Captura de tela que mostra a opção de usar um ponto de extremidade personalizado.

  2. Na página Adicionar origem , selecione Ativar para Associação de Esquema e, em seguida, selecione Adicionar.

    Captura de tela de um endpoint personalizado com uma opção para associar esquemas.

  3. No editor, para associar a um novo esquema ou a um esquema existente de um repositório de esquemas, selecione Associar esquema de eventos na faixa de opções.

    Captura de tela do editor de fluxo de eventos com o botão para associar um esquema de eventos selecionado na faixa de opções.

  4. Para usar um esquema existente, selecione Escolher no registro de esquema de eventos e siga estas etapas:

    1. Na caixa de diálogo Associar um esquema de evento, selecione um esquema no registro de esquemas. O esquema de dados de evento aparece no painel direito.

    2. Selecione Escolher para associar o esquema de eventos ao ponto de extremidade personalizado.

      Captura de tela da caixa de diálogo para associar um esquema de evento a um esquema selecionado no registro de esquema.

    3. No editor de eventstream, selecione o tile eventstream. No painel inferior, alterne para a guia Esquema Associado . Confirme se o esquema está associado ao fluxo de eventos.

      Captura de tela do editor de eventstream com um fluxo de eventos selecionado e a guia de um esquema associado realçado.

  5. Use uma das seguintes opções para criar um esquema:

    • Se você tiver um arquivo JSON de esquema, selecione Carregar para carregar o arquivo. Para obter um arquivo de exemplo, consulte Baixar um esquema de evento.

      Captura de tela que mostra a opção de upload para criar um esquema.

    • Comece a criar um esquema manualmente selecionando Adicionar linha. Para cada linha, selecione o tipo de campo, selecione o nome do campo e, opcionalmente, insira uma descrição.

      Captura de tela que mostra a maneira manual de criar um esquema.

    • Para criar um esquema inserindo o código JSON, selecione a opção editor de código . Se a mensagem Se você optar por usar o editor de código para criar seu esquema, observe que não será possível alternar de volta para o construtor de interface do usuário , selecione Editar.

      Captura de tela que mostra o editor de código para criar um esquema.

      Insira o código JSON no editor.

      Captura de tela que mostra o código JSON no editor de código para criar um esquema.

Observação

Um fluxo de eventos pode dar suporte a até 11 origens e destinos combinados somente quando você estiver usando os seguintes tipos:

  • Fonte: ponto de extremidade personalizado.
  • Destinos: Endpoint personalizado e eventhouse com ingestão direta.

As fontes ou destinos não incluídos na lista anterior e os destinos não acrescentados ao fluxo padrão não contam para esse limite.

Obter detalhes do ponto de extremidade no painel Detalhes

Depois que você criar uma origem do ponto de extremidade personalizado, seus dados ficarão disponíveis para visualização na exibição ao vivo.

Captura de tela mostrando o eventstream no modo de exibição ao vivo.

O painel Detalhes tem três guias de protocolo: Hub de Eventos, AMQP e Kafka. Cada aba de protocolo tem duas páginas que oferecem os detalhes do endpoint com o protocolo correspondente para conexão.

  • Básico mostra o nome, o tipo e o status do seu endpoint personalizado.

    Captura de tela mostrando informações básicas no painel Detalhes do modo de exibição ao vivo do eventstream.

  • A Autenticação de Chave SAS fornece informações sobre chaves de conexão. Ele também fornece um link para o código de exemplo, com as chaves correspondentes inseridas, que você pode usar para transmitir os eventos para o fluxo de eventos. As informações nesta página variam de acordo com o protocolo.

Hub de eventos

A guia Autenticação de Chave SAS para o protocolo hub de eventos contém informações relacionadas à cadeia de conexão de um hub de eventos. As informações incluem nome do hub de eventos, nome da chave de acesso compartilhado, chave primária, chave secundária, chave primária da cadeia de conexão e chave secundária da cadeia de conexão.

Captura de tela mostrando informações de chaves no painel Detalhes do eventstream.

O formato do hub de eventos é o padrão da cadeia de conexão, e funciona com o SDK de Hubs de Eventos do Azure. Esse formato permite que você se conecte ao seu eventstream por meio do protocolo do Hubs de Eventos.

O exemplo a seguir mostra a aparência da cadeia de conexão no formato do hub de eventos:

Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

Se você selecionar o botão Mostrar código de exemplo , verá o código Java pronto para uso que inclui as informações necessárias sobre chaves de conexão no hub de eventos. Copie e cole-o no seu aplicativo para usá-lo.

Captura de tela que mostra o botão para mostrar o código de exemplo no painel Detalhes do modo de exibição ao vivo eventstream.

AMQP

O formato AMQP (Advanced Message Queuing Protocol) é compatível com o AMQP 1.0, que é um protocolo de mensagens padrão que dá suporte à interoperabilidade entre várias plataformas e idiomas. Você pode usar esse formato para se conectar ao seu eventstream usando o protocolo AMQP.

Captura de tela mostrando as chaves do AMQP no painel Detalhes do modo de exibição ao vivo do eventstream.

Ao selecionar o botão Mostrar código de exemplo , você verá o código Java pronto para uso com informações de chave de conexão no formato AMQP.

Captura de tela que mostra o botão para mostrar o código de exemplo AMQP no painel Detalhes do modo de exibição ao vivo do fluxo de eventos.

Kafka

O formato Kafka é compatível com o protocolo do Apache Kafka, que é uma plataforma popular de streaming distribuída que dá suporte ao processamento de dados de alta taxa de transferência e baixa latência. Você pode usar as informações da Autenticação de Chave SAS no formato do protocolo do Kafka para se conectar ao fluxo de eventos e transmitir os eventos.

Captura de tela mostrando as chaves do Kafka no painel Detalhes do modo de exibição ao vivo do eventstream.

Ao selecionar o botão Mostrar código de exemplo, você verá o código Java pronto para uso, inclusive as chaves de conexão necessárias no formato Kafka. Copie-o para usá-lo.

Captura de tela que mostra o botão do código de exemplo do Kafka no painel de detalhes da visualização ao vivo do stream de eventos.

Para obter um guia claro sobre como usar o ponto de extremidade personalizado com o protocolo Kafka, consulte este tutorial. Ele fornece etapas detalhadas para streaming e consumo de eventos.

Observação

  • Você pode escolher o formato de protocolo que atender às necessidades e preferências do seu aplicativo e, a seguir, copiar e colar a cadeia de conexão no seu aplicativo. Você também pode consultar ou copiar o código de exemplo, que mostra como enviar ou receber eventos usando vários protocolos.
  • Para fechar a exibição de código de exemplo, selecione Ocultar código de exemplo.

Configurar destinos de fluxo de eventos para usar esquemas

Atualmente, apenas o eventhouse, o endpoint personalizado e os destinos de streams derivados têm suporte para fluxos de eventos com recursos estendidos habilitados. Esta seção mostra como adicionar e configurar um destino de casa de eventos quando recursos estendidos (como suporte a esquema) estiverem habilitados para o fluxo de eventos.

Configurar um schema para um destino de endpoint personalizado

  1. Selecione Transformar eventos ou adicionar destino e selecione CustomEndpoint.

  2. No painel ponto de extremidade personalizado , especifique um nome para o destino.

  3. Para o esquema de entrada, selecione o esquema para eventos. Você faz uma seleção nesta caixa ao habilitar o suporte de esquema para um fluxo de eventos.

Captura de tela que mostra o painel para configurar um ponto de extremidade personalizado.

Para obter etapas detalhadas sobre como configurar um destino de ponto de extremidade personalizado, consulte Adicionar um ponto de extremidade personalizado ou um destino de aplicativo personalizado a um fluxo de eventos.

Configurar esquemas para um destino de gerenciamento de eventos

  1. Selecione Transformar eventos ou adicionar destino e selecione Eventhouse.

  2. No painel Eventhouse , defina as seguintes configurações relacionadas ao esquema:

    1. Para o esquema de entrada, selecione um ou mais esquemas na lista suspensa.

      Captura de tela que mostra o painel de configuração do eventhouse com um esquema de entrada selecionado.

      Observação

      Se você selecionou o esquema dinâmico por meio da opção de cabeçalhos ao configurar uma origem dos Hubs de Eventos, talvez tenha configurado vários esquemas para a origem e mapeado-os para várias propriedades e seus valores.

    2. Para o método de criação de tabela, selecione Uma única tabela com todos os esquemas combinados ou tabelas separadas para cada esquema, dependendo de seus requisitos.

      Captura de tela que mostra o painel de configuração do eventhouse com métodos de criação de tabela.

    3. Para gravar dados com, selecione uma das seguintes opções:

      • Apenas carga útil: Escreva dados de carga útil extraídos na tabela. Se houver vários esquemas de entrada, os dados serão enviados para várias tabelas.
      • Metadados e payload: Gravar metadados e dados de payload em uma única tabela. As colunas de exemplo incluem source , subjecte typedata.

      Captura de tela que mostra o painel de configuração do eventhouse com as opções para gravar dados.

Para obter etapas detalhadas sobre como configurar um destino de casa de eventos, consulte Adicionar um destino de casa de eventos a um fluxo de eventos.