Conectar-se a um hub de eventos a partir dos fluxos de trabalho nos Aplicativos Lógicos do Azure

Aplica-se a: Aplicativos Lógicos do Azure (Consumo)

O conector dos Hubs de Eventos do Azure ajuda você a conectar seus fluxos de trabalho do aplicativo lógico aos hubs de eventos no Azure. Então, você pode fazer com que seus fluxos de trabalho monitorem e gerenciem eventos que são enviados a um hub de eventos. Por exemplo, seu fluxo de trabalho pode verificar, enviar e receber eventos do hub de eventos. Este artigo fornece um guia de início para usar o conector dos Hubs de Eventos do Azure, mostrando como se conectar a um hub de eventos e adicionar um gatilho ou ação dos Hubs de Eventos ao fluxo de trabalho.

Para obter mais informações sobre os Hubs de Eventos do Azure ou os Aplicativos Lógicos do Azure, confira O que são os Hubs de Eventos do Azure ou O que são os Aplicativos Lógicos do Azure.

Operações disponíveis

Para todas as operações e outras informações técnicas, como propriedades, limites e assim por diante, consulte a Página de referência do conector dos Hub de Eventos.

Observação

Para aplicativos lógicos hospedados em um ISE (ambiente de serviço de integração), a versão do ISE do conector usa os limites de mensagem do ISE.

Pré-requisitos

Verifique as permissões e obtenha a cadeia de conexão

Para garantir que seu fluxo de trabalho acesse o hub de eventos, verifique suas permissões e obtenha a cadeia de conexão para o namespace de seu hub de eventos.

  1. No portal do Azure, vá até os namespaces dos seus Hubs de Eventos, não um hub de eventos específico.

  2. No menu do namespace, em Configurações, selecione Políticas de acesso compartilhado. Na coluna Declarações, verifique se você tem pelo menos permissões para Gerenciar esse namespace.

    Screenshot showing the Azure portal, your Event Hubs namespace, and

  3. Se quiser inserir manualmente suas informações de conexão mais tarde, obtenha a cadeia de caracteres de conexão para o namespace do hub de eventos.

    1. Na coluna Política, selecione RootManageSharedAccessKey.

    2. Localize a cadeia de conexão da chave primária. Copie e salve a cadeia de conexão para uso posterior.

      Screenshot showing the primary key's connection string with the copy button selected.

      Dica

      Para confirmar se a cadeia de conexão está associada ao namespace de Hubs de Eventos ou a um hub de eventos específico, certifique-se de que a cadeia de conexão não tenha o parâmetro EntityPath. Se você encontrar esse parâmetro, a cadeia de conexão servirá para uma "entidade" dos Hubs de Eventos específica e não será a cadeia de caracteres correta a ser usada com seu fluxo de trabalho.

Criar uma conexão do hub de eventos

Ao adicionar uma ação ou gatilho dos Hubs de Eventos pela primeira vez, você será solicitado a criar uma conexão com seu hub de eventos.

  1. Quando for solicitado, escolha uma das seguintes opções:

    • Forneça as seguintes informações de conexão:

      Propriedade Obrigatório Valor Descrição
      Nome da conexão Yes <connection-name> O nome a criar para a conexão
      Namespace dos Hubs de Eventos Sim <event-hubs-namespace> Selecione o namespace dos Hubs de Eventos que você quer usar.
    • Para inserir de forma manual sua cadeia de conexão salva anteriormente, escolha Inserir manualmente as informações de conexão. Saiba como localizar a cadeia de conexão.

  2. Selecione a política do Hubs de Eventos a ser usada, se ainda não estiver selecionada, e, em seguida, selecione Criar.

    Screenshot showing the provided connection information with

  3. Depois de criar a conexão, continue com Adicionar um gatilho dos Hubs de Eventos ou Adicionar uma ação dos Hubs de Eventos.

Adicionar gatilho dos Hubs de Eventos

Nos Aplicativos Lógicos do Azure, cada fluxo de trabalho deve começar com um gatilho, que é disparado quando uma condição específica é atendida. Sempre que o gatilho é acionado, o serviço de Aplicativos Lógicos cria uma instância de fluxo de trabalho e começa a executar as etapas no fluxo de trabalho.

As etapas a seguir descrevem a maneira geral de se adicionar um gatilho, por exemplo, Quando os eventos estão disponíveis no Hub de Eventos. Este exemplo mostra como adicionar um gatilho que verifica se há novos eventos em seu hub de eventos e inicia a execução de um fluxo de trabalho quando novos eventos existem.

  1. No Designer do Aplicativos Lógicos, abra o seu fluxo de trabalho em branco, se ainda não estiver aberto.

  2. Na caixa de pesquisa de operações, digite event hubs. Na lista de gatilhos, selecione este gatilho com o nome Quando os eventos estão disponíveis no Hub de Eventos.

    Select trigger

  3. Se você for solicitado a criar uma conexão com seu hub de eventos, forneça as informações de conexão solicitadas.

  4. No gatilho, forneça informações sobre o hub de eventos que você deseja monitorar, por exemplo:

    Propriedade Obrigatório Descrição
    Nome do Hub de Eventos Sim O nome do hub de eventos que você deseja monitorar
    Tipo de conteúdo Não Tipo de conteúdo do evento. O padrão é application/octet-stream.
    Nome do grupo de consumidor Não O nome do grupo de consumidores dos Hubs de Eventos a ser usado na leitura dos eventos. Se não especificado, será usado o grupo de consumidores padrão.
    Contagem máxima de eventos Não O número máximo de eventos. O gatilho retorna entre um e o número de eventos especificado por essa propriedade.
    Intervalo Sim Um inteiro positivo que descreve quantas vezes o fluxo de trabalho é executado com base na frequência
    Frequência Sim A unidade de tempo para a recorrência

    Para obter mais propriedades, abra a lista Adicionar novo parâmetro. A seleção de um parâmetro adiciona essa propriedade ao gatilho, por exemplo:

    Trigger properties

    Mais propriedades

    Propriedade Obrigatório Descrição
    Esquema de conteúdo Não O esquema de conteúdo JSON para os eventos a ser lido do hub de eventos. Por exemplo, se você especificar o esquema de conteúdo, poderá disparar o gatilho do fluxo de trabalho somente para os eventos que correspondam àquele esquema.
    Chave de partição mínima Não Insira a ID de partição mínima para leitura. Por padrão, todas as partições são lidas.
    Chave de partição máxima Não Insira a ID de participação para leitura. Por padrão, todas as partições são lidas.
    Fuso horário Não Aplica-se somente quando você especifica uma hora de início, porque o gatilho não aceita diferença UTC. Selecione o fuso horário que você deseja aplicar.

    Para obter mais informações, consulte Criar e executar tarefas e fluxos de trabalho recorrentes com os Aplicativos Lógicos do Azure.

    Hora de início Não Forneça uma hora de início neste formato:

    AAAA-MM-DDThh:mm:ss se você selecionar um fuso horário

    -ou-

    AAAA-MM-DDThh:mm:ssZ se você não selecionar um fuso horário

    Para obter mais informações, consulte Criar e executar tarefas e fluxos de trabalho recorrentes com os Aplicativos Lógicos do Azure.

  5. Quando terminar, selecione Salvar na barra de ferramentas do designer.

  6. Agora, continue adicionando uma ou mais ações para que você possa executar outras tarefas usando as saídas do gatilho.

    Por exemplo, para filtrar eventos com base em um valor específico, como uma categoria, você pode adicionar uma condição para que a ação Enviar evento envie somente os eventos que atendam à sua condição.

Comportamento de sondagem do gatilho

Todos os gatilhos dos Hubs de Eventos são gatilhos de sondagem longa. Esse comportamento significa que, ao disparar, o gatilho processa todos os eventos e aguarda 30 segundos para que mais eventos apareçam no seu hub de eventos. Por definição, se nenhum evento aparecer em 30 segundos, o gatilho será ignorado. Caso contrário, o gatilho continuará lendo os eventos até que seu hub de eventos esteja vazio. A próxima sondagem de gatilhos acontece com base no intervalo de recorrência que você especificar nas propriedades do gatilho.

Por exemplo, se o gatilho estiver configurado com quatro partições, esse atraso poderá levar até dois minutos antes que o gatilho termine a sondagem de todas as partições. Se nenhum evento for recebido dentro desse tempo de atraso, a execução de gatilho será ignorada. Caso contrário, o gatilho continuará lendo os eventos até que seu hub de eventos esteja vazio. A próxima pesquisa de gatilhos acontecerá com base no intervalo de recorrência que você especificar nas propriedades do gatilho.

Se você souber as partições específicas onde as mensagens são exibidas, poderá atualizar o gatilho para ler eventos somente dessa(s) partição(ões) definindo as chaves de partição máxima e mínima do gatilho. Para obter mais informações, consulte a seção Adicionar gatilho dos Hubs de Eventos.

Disparar comportamento de ponto de verificação

Quando um gatilho dos Hubs de Eventos lê eventos de cada partição em um hub de eventos, o disparador usa seu próprio estado para manter informações sobre o deslocamento do fluxo (a posição do evento em uma partição) e as partições de onde o gatilho lê os eventos.

Cada vez que o fluxo de trabalho é executado, o gatilho lê eventos de uma partição, começando do deslocamento do fluxo que é mantido pelo estado do gatilho. No modo round-robin, o gatilho itera em cada partição no hub de eventos e lê os eventos nas execuções de gatilho subsequentes. Uma única execução obtém eventos de uma única partição de cada vez.

O gatilho não usa esse recurso de ponto de verificação no armazenamento, o que não resulta em custo extra. No entanto, o ponto-chave é que a atualização do gatilho dos Hubs de Eventos redefine o estado do gatilho, o que pode fazer com que o gatilho leia eventos no início do fluxo.

Adicionar ação dos Hubs de Eventos

Nos Aplicativos Lógicos do Azure, uma ação segue um gatilho ou outra ação e executa alguma operação em seu fluxo de trabalho. As etapas a seguir descrevem a maneira usual de adicionar uma ação, por exemplo, Enviar evento. Para este exemplo, o fluxo de trabalho começa com um gatilho dos Hubs de Eventos que verifica novos eventos em seu hub de eventos.

  1. No Designer dos Aplicativos Lógicos, abra o seu fluxo de trabalho do aplicativo lógico, se ainda não estiver aberto.

  2. Em gatilho ou outra ação, adicione uma nova etapa.

    Para adicionar uma ação entre etapas existentes, mova o mouse sobre a seta. Selecione o sinal de adição ( + ) que aparece e, em seguida, selecione +.

  3. Na caixa de pesquisa de operações, digite event hubs. Na lista de ações, selecione a ação chamada Enviar evento.

    Select

  4. Se você for solicitado a criar uma conexão com seu hub de eventos, forneça as informações de conexão solicitadas.

  5. Na ação, forneça as informações sobre os eventos que você deseja enviar.

    Propriedade Obrigatório Descrição
    Nome do Hub de Eventos Sim O hub de eventos para o qual você quer enviar o evento
    Sumário Não O conteúdo do evento que você quer enviar
    Propriedades Não As propriedades e os valores do aplicativo a serem enviados
    Chave de partição Não A ID da partição para onde enviar o evento

    Para obter mais propriedades, abra a lista Adicionar novo parâmetro. A seleção de um parâmetro adiciona a propriedade à ação, por exemplo:

    Select event hub name and provide event content

    Por exemplo, você pode enviar a saída do seu gatilho dos Hubs de Eventos para outro hub de eventos:

    Send event example

  6. Quando terminar, selecione Salvar na barra de ferramentas do designer.

Referência do conector

Para todas as operações e outras informações técnicas, como propriedades, limites e assim por diante, consulte a Página de referência do conector dos Hub de Eventos.

Observação

Para aplicativos lógicos hospedados em um ISE (ambiente de serviço de integração), a versão do ISE do conector usa os limites de mensagem do ISE.

Próximas etapas