Werkstromen verbinden met Event Hubs in Azure Logic Apps

Van toepassing op: Azure Logic Apps (Verbruik + Standard)

Als u taken wilt automatiseren die gebeurtenissen in een Event Hub bewaken en beheren vanuit uw werkstroom in Azure Logic Apps, gebruikt u de bewerkingen van de Azure Event Hubs-connector . Uw werkstroom kan bijvoorbeeld gebeurtenissen controleren, verzenden en ontvangen van uw Event Hub.

In dit artikel wordt beschreven hoe u verbinding maakt met uw Event Hub door een Event Hubs-trigger of -actie toe te voegen aan uw werkstroom.

Naslaginformatie over connectors

Zie de referentiepagina van de Event Hubs-connector voor informatie over de bewerkingen van deze connector, hun parameters en andere technische informatie, zoals limieten, bekende problemen, enzovoort.

Vereisten

• Een Azure-account en -abonnement. Als u nog geen abonnement hebt, meld u dan aan voor een gratis Azure-account.

• Een Event Hubs-naamruimte en Event Hub.

  Controleer of uw werkstroom toegang heeft tot uw Event Hub. Ga als volgt te werk om deze taak te voltooien:

  1. Ga in Azure Portal naar uw Event Hubs-naamruimte, niet naar een specifieke Event Hub.

  2. Selecteer in het naamruimtemenu onder Instellingen het beleid voor gedeelde toegang. Controleer in de kolom Claims of u ten minste machtigingen voor die naamruimte hebt.

     Opmerking

     Wanneer u later een verbinding met uw Event Hubs-naamruimte maakt, wordt u gevraagd een verificatietype voor de verbinding te selecteren. Op basis van de selectie van het verificatietype hebt u mogelijk de verbindingsreeks voor de naamruimte nodig. Voor toegangssleutelverificatie is bijvoorbeeld deze verbindingsreeks vereist.

  3. Als u van plan bent om later een verificatietype te selecteren waarvoor de verbindingsreeks voor uw Event Hubs-naamruimte is vereist, slaat u die tekenreeks nu op, zodat u deze gegevens later kunt invoeren:

     1. Selecteer RootManageSharedAccessKey in de kolom Beleid.

     2. Zoek de verbindingsreeks van uw primaire sleutel. Kopieer en sla de verbindingsreeks op voor later gebruik.

        Als u wilt controleren of uw verbindingsreeks deel uitmaakt van uw Event Hubs-naamruimte en niet een specifieke Event Hub, moet u ervoor zorgen dat de verbindingsreeks niet over de EntityPath parameter beschikt. Als u deze parameter vindt, behoort de verbindingsreeks tot een Event Hub en is deze niet de juiste tekenreeks voor gebruik met uw werkstroom.

        

• De werkstroom van de logische app waar u toegang wilt krijgen tot uw Event Hub

  Als u uw werkstroom wilt starten met een Event Hubs-trigger, hebt u een lege werkstroom nodig. Als u een Event Hubs-actie in uw werkstroom wilt gebruiken, kunt u elke trigger gebruiken die het beste werkt voor uw scenario om uw werkstroom te starten.

Een Event Hubs-trigger toevoegen

In Azure Logic Apps moet elke werkstroom beginnen met een trigger, die wordt geactiveerd wanneer aan een specifieke voorwaarde wordt voldaan. Telkens wanneer de trigger wordt geactiveerd, wordt in Azure Logic Apps een exemplaar van uw werkstroom gemaakt en worden de stappen in de werkstroom uitgevoerd.

In de volgende stappen wordt de algemene manier beschreven om een Event Hubs-trigger toe te voegen, zoals Wanneer gebeurtenissen beschikbaar zijn in Event Hub. Met deze voorbeeld-trigger wordt gecontroleerd op nieuwe gebeurtenissen in uw Event Hub en wordt een werkstroom gestart wanneer er nieuwe gebeurtenissen zich voordoen.

1. Open uw logische app-resource in Azure Portal.

2. Afhankelijk van of u een Consumption- of Standard-logic app-resource hebt, volgt u de bijbehorende stappen.

   • Verbruik: Selecteer in de zijbalk van de resource onder Ontwikkelhulpprogramma's de ontwerpfunctie om uw lege werkstroom te openen.

   • Standaard: Selecteer op de zijbalk van de resource onder Werkstromen de optie Werkstromen en selecteer vervolgens uw lege werkstroom. Selecteer in de zijbalk van de werkstroom onder Extra de ontwerpfunctie om de lege werkstroom te openen.

3. Volg deze algemene stappen in de ontwerpfunctie om de Event Hubs-trigger toe te voegen die u aan uw werkstroom wilt toevoegen.

   Zie Event Hubs - Triggers voor meer informatie. In dit voorbeeld wordt de trigger met de naam Wanneer gebeurtenissen beschikbaar zijn in Event Hub voortgezet. Deze trigger controleert op nieuwe gebeurtenissen in uw Event Hub en start een werkstroomuitvoering wanneer er nieuwe gebeurtenissen bestaan.

4. Als u hierom wordt gevraagd, geeft u de verbindingsgegevens op voor uw Event Hub.

5. Geef in de trigger de benodigde informatie op voor de geselecteerde trigger.

   Voor de voorbeeldtrigger beschrijven de volgende tabellen de beschikbare parameters, te beginnen met de volgende standaardparameter:

   Kenmerk	Vereist	Beschrijving
   Event Hub-naam	Ja	De naam voor de Event Hub die moet worden bewaakt.

   Onder Hoe vaak wilt u controleren op items, zijn de volgende standaardparameters beschikbaar:

   Kenmerk	Vereist	Beschrijving
   Interval	Ja	Een positief geheel getal dat beschrijft hoe vaak de werkstroom wordt uitgevoerd op basis van de frequentie.
   Frequentie	Ja	De tijdseenheid voor de herhaling.
   Tijdzone	Nee	Is alleen van toepassing wanneer u een begintijd opgeeft omdat deze trigger geen UTC-offset accepteert. Selecteer de tijdzone die u wilt toepassen. Zie Terugkerende werkstromen plannen en uitvoeren voor meer informatie.
   Begintijd	Nee	Geef een begintijd op in deze indeling: JJJJ-MM-DDThh:mm:ss als u een tijdzone selecteert – of – JJJJ-MM-DDThh:mm:ssZ als u geen tijdzone selecteert Zie Terugkerende werkstromen plannen en uitvoeren voor meer informatie.

   In de lijst geavanceerde parameters zijn de volgende optionele parameters beschikbaar:

   Kenmerk	Vereist	Beschrijving
   Inhoudstype	Nee	Het inhoudstype van de gebeurtenis. De standaardwaarde is toepassing/octet-stream.
   Inhoudsschema	Nee	Het inhoudsschema van de gebeurtenis.
   Naam van consumentengroep	Nee	De naam voor de Event Hubs-consumentengroep die moet worden gebruikt voor het lezen van gebeurtenissen. Indien niet opgegeven, wordt de standaardconsumentengroep gebruikt.
   Minimale partitiesleutel	Nee	Voer de minimale partitie-id in die moet worden gelezen. Standaard worden alle partities gelezen.
   Maximale partitiesleutel	Nee	Voer de maximale partitie-id in die moet worden gelezen. Standaard worden alle partities gelezen.
   Maximumaantal gebeurtenissen	Nee	Het maximum aantal gebeurtenissen. De trigger retourneert tussen één en het aantal gebeurtenissen dat door deze eigenschap is opgegeven.

6. Als u klaar bent, selecteert u Opslaan op de werkbalk in de ontwerper.

7. Ga nu door met het toevoegen van een of meer acties, zodat u andere taken kunt uitvoeren met behulp van de triggeruitvoer.

   Als u bijvoorbeeld gebeurtenissen wilt filteren op basis van een specifieke waarde, zoals een categorie, kunt u een voorwaarde toevoegen, zodat de actie Gebeurtenis verzenden alleen de gebeurtenissen verzendt die voldoen aan uw voorwaarde.

Triggergedrag

Pollinggedrag activeren

Alle Event Hubs-triggers zijn lang polling-triggers. Dit gedrag betekent dat wanneer een trigger wordt geactiveerd, de trigger alle gebeurtenissen verwerkt en 30 seconden wacht tot er meer gebeurtenissen in uw Event Hub worden weergegeven. Als er in 30 seconden geen gebeurtenissen worden weergegeven, wordt de trigger standaard overgeslagen. Anders blijft de trigger gebeurtenissen lezen totdat uw Event Hub leeg is. De volgende trigger poll vindt plaats op basis van het terugkeerinterval dat u hebt ingesteld in de eigenschappen van de trigger.

Als de trigger bijvoorbeeld is ingesteld met vier partities, kan deze vertraging maximaal twee minuten duren voordat de trigger klaar is met het peilen van alle partities. Als er binnen deze vertraging geen gebeurtenissen worden ontvangen, wordt de triggeruitvoering overgeslagen. Anders blijft de trigger gebeurtenissen lezen totdat uw Event Hub leeg is. De volgende trigger poll vindt plaats op basis van het terugkeerinterval dat u opgeeft in de eigenschappen van de trigger.

Als u de specifieke partities kent waarin de berichten worden weergegeven, kunt u de trigger bijwerken om alleen gebeurtenissen van die partities te lezen. Stel de maximum- en minimale partitiesleutels van de trigger in. Raadpleeg de sectie Event Hubs-trigger toevoegen voor meer informatie.

Gedrag van triggercontrolepunt

Wanneer een Event Hubs-trigger gebeurtenissen uit elke partitie in een Event Hub leest, behoudt de trigger zijn eigen status om gegevens te bewaren over de stream offset (de gebeurtenispositie in een partitie) en de partities waarvan de trigger gebeurtenissen leest.

Telkens wanneer uw workflow wordt uitgevoerd, leest de trigger gebeurtenissen uit een partitie, te beginnen met de stream-offset die is opgeslagen in de triggerstatus. In round robin wordt de trigger herhaald over elke partitie in de Event Hub en worden gebeurtenissen gelezen in volgende triggeruitvoeringen. Met één uitvoering worden gebeurtenissen van één partitie tegelijk opgehaald.

De trigger gebruikt deze controlepuntmogelijkheid niet in de opslag, wat resulteert in geen extra kosten. Als u de Event Hubs-trigger bijwerkt, wordt de status van de trigger opnieuw ingesteld, waardoor de trigger gebeurtenissen aan het begin van de stream kan lezen.

Azure Event Hubs actie toevoegen

In Azure Logic Apps volgt een actie de trigger of een andere actie en voert een bepaalde taak uit in uw werkstroom. In de volgende stappen wordt de algemene manier beschreven om een Event Hubs-actie toe te voegen, zoals Een gebeurtenis verzenden. In dit voorbeeld begint de werkstroom met een Event Hubs-trigger die controleert op nieuwe gebeurtenissen in de Event Hub.

1. Open uw logische app-resource in Azure Portal.

2. Afhankelijk van of u een Consumption- of Standard-logic app-resource hebt, volgt u de bijbehorende stappen.

   • Verbruik: Selecteer in de zijbalk van de resource onder Ontwikkelhulpprogramma's de ontwerpfunctie om uw werkstroom te openen.

   • Standaard: Selecteer op de zijbalk van de resource onder Werkstromen de optie Werkstromen en selecteer vervolgens uw werkstroom. Selecteer in de zijbalk van de werkstroom onder Extra de ontwerpfunctie om de werkstroom te openen.

3. Volg deze algemene stappen in de ontwerpfunctie om de Event Hubs-actie toe te voegen die u aan uw werkstroom wilt toevoegen.

   Zie Event Hubs - Acties voor meer informatie. In dit voorbeeld wordt doorgegaan met de actie genaamd Verstuur evenement.

4. Als u hierom wordt gevraagd, geeft u de verbindingsgegevens op voor uw Event Hub.

5. Geef in de actie de benodigde informatie op voor de geselecteerde actie.

   Voor de voorbeeldactie beschrijven de volgende tabellen de beschikbare parameters, te beginnen met de volgende standaardparameter:

   Kenmerk	Vereist	Beschrijving
   Event Hub-naam	Ja	De naam voor de Event Hub waar u de gebeurtenis wilt verzenden.

   In de lijst geavanceerde parameters zijn de volgende optionele parameters beschikbaar:

   Kenmerk	Vereist	Beschrijving
   Partitiesleutel	Nee	De partitie-id voor waar de gebeurtenis moet worden verzonden.
   Inhoud	Nee	De inhoud voor de gebeurtenis die u wilt verzenden.
   Eigenschappen	Nee	De app-eigenschappen en -waarden die moeten worden verzonden.

   U kunt bijvoorbeeld de uitvoer van de Event Hubs-trigger verzenden naar een andere Event Hub:

   

6. Als u klaar bent, selecteert u Opslaan op de werkbalk in de ontwerper.

Een verbinding maken

Wanneer u een Event Hubs-trigger of -actie voor de eerste keer toevoegt, wordt u gevraagd een verbinding met uw Event Hub te maken. Geef voor deze verbinding de volgende informatie op en selecteer Nieuwe maken:

Nadat u de verbinding hebt gemaakt, gaat u verder met een Event Hubs-trigger toevoegen of een Event Hubs-actie toevoegen.

Verwante inhoud

• Wat zijn connectors in Azure Logic Apps?
• Beheerde connectors voor Azure Logic Apps