Conectar-se a um hub de eventos a partir de fluxos de trabalho nos Aplicativos Lógicos do Azure
Aplica-se a: Aplicativos Lógicos do Azure (Consumo)
O conector de Hubs de Eventos do Azure ajuda você a conectar seus fluxos de trabalho de aplicativos lógicos a hubs de eventos no Azure. Em seguida, você pode fazer com que seus fluxos de trabalho monitorem e gerenciem eventos que são enviados para um hub de eventos. Por exemplo, seu fluxo de trabalho pode verificar, enviar e receber eventos do seu hub de eventos. Este artigo fornece um guia de introdução ao uso do conector de Hubs de Eventos do Azure mostrando como se conectar a um hub de eventos e adicionar um gatilho ou ação de Hubs de Eventos ao seu fluxo de trabalho.
Para obter mais informações sobre Hubs de Eventos do Azure ou Aplicativos Lógicos do Azure, consulte O que são Hubs de Eventos do Azure ou O que são 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, revise a página de referência do conector de Hubs de Eventos.
Pré-requisitos
Uma conta e subscrição do Azure. Se não tiver uma subscrição do Azure, inscreva-se para obter uma conta do Azure gratuita.
Um namespace de Hubs de Eventos e um hub de eventos
O fluxo de trabalho do aplicativo lógico onde você deseja acessar seu hub de eventos
Para iniciar um fluxo de trabalho com um gatilho de Hubs de Eventos, você precisa de um fluxo de trabalho vazio. Se você é novo nos Aplicativos Lógicos do Azure, tente este início rápido para criar um exemplo de fluxo de trabalho de aplicativo lógico de consumo.
Verifique as permissões e obtenha a cadeia de conexão
Para garantir que seu fluxo de trabalho possa acessar seu hub de eventos, verifique suas permissões e obtenha a cadeia de conexão para o namespace do hub de eventos.
No portal do Azure, vá para o namespace dos Hubs de Eventos, não para um hub de eventos específico.
No menu namespace, em Configurações, selecione Políticas de acesso compartilhado. Na coluna Declarações, verifique se você tem pelo menos Gerenciar permissões para esse namespace.
Se, posteriormente, desejar inserir manualmente as informações de conexão, obtenha a cadeia de conexão para o namespace do hub de eventos.
Na coluna Política, selecione RootManageSharedAccessKey.
Encontre a cadeia de conexão da chave primária. Copie e salve a cadeia de conexão para uso posterior.
Gorjeta
Para confirmar se a cadeia de conexão está associada ao namespace dos Hubs de Eventos ou a um hub de eventos específico, verifique se a cadeia de conexão não tem o
EntityPathparâmetro. Se você encontrar esse parâmetro, a cadeia de conexão será para uma "entidade" específica dos Hubs de Eventos e não será a cadeia de caracteres correta a ser usada com seu fluxo de trabalho.
Criar uma conexão de hub de eventos
Ao adicionar um gatilho ou ação de Hubs de Eventos pela primeira vez, você será solicitado a criar uma conexão com seu hub de eventos.
Quando lhe for pedido, escolha uma das seguintes opções:
Forneça as seguintes informações de conexão:
Property Necessário Valor Description Nome da Ligação Sim <nome da conexão> O nome a criar para a sua ligação Namespace de Hubs de Eventos Sim <event-hubs-namespace> Selecione o namespace Hubs de Eventos que você deseja usar. Para inserir manualmente a cadeia de conexão salva anteriormente, selecione Inserir manualmente as informações de conexão. Saiba como encontrar sua cadeia de conexão.
Selecione a política de Hubs de Eventos a ser usada, se ainda não estiver selecionada, e selecione Criar.
Depois de criar sua conexão, continue com Adicionar um gatilho de Hubs de Eventos ou Adicionar uma ação de Hubs de Eventos.
Adicionar o acionador do Hubs de Eventos
Nos Aplicativos Lógicos do Azure, cada fluxo de trabalho deve começar com um gatilho, que é acionado quando uma condição específica é atendida. Sempre que o gatilho é acionado, o serviço 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 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 no hub de eventos e inicia uma execução de fluxo de trabalho quando novos eventos existem.
No Designer de Aplicativos Lógicos, abra o fluxo de trabalho do aplicativo lógico em branco, se ainda não estiver aberto.
Na caixa de pesquisa da operação, digite
event hubs. Na lista de gatilhos, selecione o gatilho chamado Quando os eventos estiverem disponíveis no Hub de Eventos.
Se você for solicitado a criar uma conexão com seu hub de eventos, forneça as informações de conexão solicitadas.
No gatilho, forneça informações sobre o hub de eventos que você deseja monitorar, por exemplo:
Property Necessário Description Nome do Hub de Eventos Sim O nome do hub de eventos que você deseja monitorar Tipo de Conteúdo Não O tipo de conteúdo do evento. A predefinição é application/octet-stream.Nome do grupo de consumidores Não O nome do grupo de consumidores de Hubs de Eventos a ser usado para ler eventos. Se não for especificado, o grupo de consumidores padrão será usado. 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 especificados por essa propriedade. Intervalo Sim Um inteiro positivo que descreve a frequência com que 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 novos parâmetros . A seleção de um parâmetro adiciona essa propriedade ao gatilho, por exemplo:
Mais propriedades
Property Necessário Description Esquema de conteúdo Não O esquema de conteúdo JSON para os eventos a serem lidos do seu hub de eventos. Por exemplo, se você especificar o esquema de conteúdo, poderá acionar o fluxo de trabalho somente para os eventos que corresponderem ao esquema. Chave de partição mínima Não Insira o ID mínimo da partição para ler. Por padrão, todas as partições são lidas. Chave de partição máxima Não Insira o ID máximo da partição para ler. Por padrão, todas as partições são lidas. Time zone (Fuso horário) Não Aplica-se somente quando você especifica uma hora de início porque esse gatilho não aceita o deslocamento UTC. Selecione o fuso horário que deseja aplicar. Para obter mais informações, consulte Criar e executar tarefas e fluxos de trabalho recorrentes com os Aplicativos Lógicos do Azure.
Start time (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
-or-
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.
Quando tiver terminado, na barra de ferramentas do estruturador, selecione Guardar.
Agora continue adicionando uma ou mais ações para que você possa executar outras tarefas usando as saídas de 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 apenas os eventos que atendem à sua condição.
Acionar o comportamento de sondagem
Todos os gatilhos de Hubs de Eventos são gatilhos de sondagem longa. Esse comportamento significa que, quando um gatilho é acionado, o gatilho processa todos os eventos e aguarda 30 segundos para que mais eventos apareçam no seu hub de eventos. Por design, se nenhum evento aparecer em 30 segundos, o gatilho será ignorado. Caso contrário, o gatilho continuará lendo eventos até que o hub de eventos esteja vazio. A próxima pesquisa de gatilho acontece com base no intervalo de recorrência definido nas propriedades do gatilho.
Por exemplo, se o gatilho estiver configurado com quatro partições, esse atraso pode levar até dois minutos antes que o gatilho termine de sondar todas as partições. Se nenhum evento for recebido dentro desse atraso, a execução do gatilho será ignorada. Caso contrário, o gatilho continuará lendo eventos até que o hub de eventos esteja vazio. A próxima pesquisa de gatilho acontece com base no intervalo de recorrência especificado nas propriedades do gatilho.
Se você souber a(s) partição(ões) específica(s) onde as mensagens aparecem, poderá atualizar o gatilho para ler eventos somente desta ou dessas partiçõ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 de Hubs de Eventos.
Acionar o comportamento do ponto de verificação
Quando um gatilho de Hubs de Eventos lê eventos de cada partição em um hub de eventos, o gatilho usa seu próprio estado para manter informações sobre o deslocamento de fluxo (a posição do evento em uma partição) e as partições de onde o gatilho lê eventos.
Cada vez que o fluxo de trabalho é executado, o gatilho lê eventos de uma partição, começando pelo deslocamento de fluxo mantido pelo estado do gatilho. Na forma round-robin, o gatilho itera sobre cada partição no hub de eventos e lê eventos em 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, resultando em nenhum custo extra. No entanto, o ponto-chave é que a atualização do gatilho de 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 ação do Hubs de Eventos
Nos Aplicativos Lógicos do Azure, uma ação segue o gatilho ou outra ação e executa alguma operação em seu fluxo de trabalho. As etapas a seguir descrevem a maneira geral de adicionar uma ação, por exemplo, Enviar evento. Neste exemplo, o fluxo de trabalho começa com um gatilho de Hubs de Eventos que verifica se há novos eventos no hub de eventos.
No Designer de Aplicativos Lógicos, abra o fluxo de trabalho do aplicativo lógico, se ainda não estiver aberto.
Sob o gatilho ou outra ação, adicione uma nova etapa.
Para adicionar uma etapa entre as etapas existentes, mova o mouse sobre a seta. Selecione o sinal de adição (+) que aparece e, em seguida, selecione Adicionar uma ação.
Na caixa de pesquisa da operação, digite
event hubs. Na lista de ações, selecione a ação chamada Enviar evento.
Se você for solicitado a criar uma conexão com seu hub de eventos, forneça as informações de conexão solicitadas.
Na ação, forneça informações sobre os eventos que você deseja enviar.
Property Necessário Description Nome do Hub de Eventos Sim O hub de eventos para onde você deseja enviar o evento Conteúdo Não O conteúdo do evento que pretende enviar Propriedades Não As propriedades e os valores do aplicativo a serem enviados Chave de partição Não O ID da partição para onde enviar o evento Para obter mais propriedades, abra a lista Adicionar novos parâmetros . A seleção de um parâmetro adiciona essa propriedade à ação, por exemplo:
Por exemplo, você pode enviar a saída do gatilho dos Hubs de Eventos para outro hub de eventos:
Quando tiver terminado, na barra de ferramentas do estruturador, selecione Guardar.
Referência do conector
Para todas as operações e outras informações técnicas, como propriedades, limites e assim por diante, revise a página de referência do conector de Hubs de Eventos.