Anslut till en händelsehubb från arbetsflöden i Azure Logic Apps
Gäller för: Azure Logic Apps (förbrukning)
Azure Event Hubs-anslutningsappen hjälper dig att ansluta dina logikapparbetsflöden till händelsehubbar i Azure. Du kan sedan låta dina arbetsflöden övervaka och hantera händelser som skickas till en händelsehubb. Ditt arbetsflöde kan till exempel kontrollera, skicka och ta emot händelser från händelsehubben. Den här artikeln innehåller en komma igång-guide för att använda Azure Event Hubs-anslutningsappen genom att visa hur du ansluter till en händelsehubb och lägger till en Event Hubs-utlösare eller åtgärd i arbetsflödet.
Mer information om Azure Event Hubs eller Azure Logic Apps finns i Vad är Azure Event Hubs eller Vad är Azure Logic Apps?
Tillgängliga åtgärder
Information om alla åtgärder och annan teknisk information, till exempel egenskaper, gränser och så vidare, finns på referenssidan för Event Hubs-anslutningsappen.
Kommentar
För logikappar som finns i en integrationstjänstmiljö (ISE) använder anslutningsappens ISE-version ISE-meddelandegränserna i stället.
Förutsättningar
Ett Azure-konto och prenumeration. Om du heller inte har någon Azure-prenumeration kan du registrera ett kostnadsfritt Azure-konto.
Arbetsflödet för logikappen där du vill komma åt din händelsehubb
Om du vill starta ett arbetsflöde med en Event Hubs-utlösare behöver du ett tomt arbetsflöde. Om du inte har använt Azure Logic Apps tidigare kan du prova den här snabbstarten för att skapa ett exempel på arbetsflödet för förbrukningslogikappen.
Kontrollera behörigheter och få anslutningssträng
Kontrollera att arbetsflödet kan komma åt din händelsehubb genom att kontrollera dina behörigheter och sedan hämta anslutningssträng för händelsehubbens namnområde.
Gå till Event Hubs-namnområdet i Azure-portalen, inte till en specifik händelsehubb.
På namnområdesmenyn går du till Inställningar och väljer Principer för delad åtkomst. I kolumnen Anspråk kontrollerar du att du har minst Hantera behörigheter för det namnområdet.
Om du senare vill ange anslutningsinformationen manuellt hämtar du anslutningssträng för händelsehubbens namnområde.
I kolumnen Princip väljer du RootManageSharedAccessKey.
Hitta primärnyckelns anslutningssträng. Kopiera och spara anslutningssträng för senare användning.
Dricks
Kontrollera om din anslutningssträng är associerad med händelsehubbens namnområde eller med en specifik händelsehubb genom att kontrollera att anslutningssträng inte har parametern
EntityPath. Om du hittar den här parametern är anslutningssträng för en specifik händelsehubb "entitet" och är inte rätt sträng att använda med ditt arbetsflöde.
Skapa en händelsehubbanslutning
När du lägger till en Event Hubs-utlösare eller åtgärd för första gången uppmanas du att skapa en anslutning till din händelsehubb.
När du uppmanas att göra det väljer du något av följande alternativ:
Ange följande anslutningsinformation:
Property Obligatoriskt Värde beskrivning Anslutningsnamn Ja <anslutningsnamn> Namnet som ska skapas för anslutningen Event Hubs-namnområde Ja <event-hubs-namespace> Välj det Event Hubs-namnområde som du vill använda. Om du vill ange dina tidigare sparade anslutningssträng manuellt väljer du Ange anslutningsinformation manuellt. Lär dig hur du hittar dina anslutningssträng.
Välj den Event Hubs-princip som ska användas, om den inte redan har valts, och välj sedan Skapa.
När du har skapat anslutningen fortsätter du med Lägg till en Event Hubs-utlösare eller Lägg till en händelsehubbåtgärd.
Lägga till Event Hubs-utlösare
I Azure Logic Apps måste varje arbetsflöde börja med en utlösare som utlöses när ett visst villkor uppfylls. Varje gång utlösaren utlöses skapar Logic Apps-tjänsten en arbetsflödesinstans och börjar köra stegen i arbetsflödet.
Följande steg beskriver det allmänna sättet att lägga till en utlösare, till exempel När händelser är tillgängliga i Händelsehubb. Det här exemplet visar hur du lägger till en utlösare som söker efter nya händelser i händelsehubben och startar en arbetsflödeskörning när nya händelser finns.
I Logic Apps Designer öppnar du ditt tomma logikapparbetsflöde, om det inte redan är öppet.
I åtgärdssökningsrutan anger du
event hubs. I listan utlösare väljer du utlösaren med namnet When events are available in Event Hub (När händelser är tillgängliga i Händelsehubb).
Om du uppmanas att skapa en anslutning till din händelsehubb anger du den begärda anslutningsinformationen.
I utlösaren anger du information om den händelsehubb som du vill övervaka, till exempel:
Property Obligatoriskt Beskrivning Namn på händelsehubb Ja Namnet på den händelsehubb som du vill övervaka Innehållstyp Nej Händelsens innehållstyp. Standardvärdet är application/octet-stream.Namn på konsumentgrupp Nej Namnet på den händelsehubbkonsumentgrupp som ska användas för att läsa händelser. Om den inte anges används standardkonsumentgruppen. Maximalt antal händelser Nej Det maximala antalet händelser. Utlösaren returnerar mellan en och antalet händelser som anges av den här egenskapen. Intervall Ja Ett positivt heltal som beskriver hur ofta arbetsflödet körs baserat på frekvensen Frekvens Ja Tidsenheten för upprepningen Om du vill ha fler egenskaper öppnar du listan Lägg till ny parameter . Om du väljer en parameter läggs den egenskapen till i utlösaren, till exempel:
Fler egenskaper
Property Obligatoriskt Beskrivning Innehållsschema Nej JSON-innehållsschemat för de händelser som ska läsas från händelsehubben. Om du till exempel anger innehållsschemat kan du bara utlösa arbetsflödet för de händelser som matchar schemat. Minsta partitionsnyckel Nej Ange det minsta partitions-ID som ska läsas. Som standard är alla partitioner lästa. Maximal partitionsnyckel Nej Ange det maximala partitions-ID som ska läsas. Som standard är alla partitioner lästa. Tidszon Nej Gäller endast när du anger en starttid eftersom den här utlösaren inte accepterar UTC-förskjutning. Välj den tidszon som du vill använda. Mer information finns i Skapa och köra återkommande uppgifter och arbetsflöden med Azure Logic Apps.
Starttid Nej Ange en starttid i det här formatet: ÅÅÅÅ-MM-DDThh:mm:ss om du väljer en tidszon
-eller-
ÅÅÅÅ-MM-DDThh:mm:ssZ om du inte väljer en tidszon
Mer information finns i Skapa och köra återkommande uppgifter och arbetsflöden med Azure Logic Apps.
När du är klar klickar du på tabelldesignern Spara på kommandofältet.
Fortsätt nu att lägga till en eller flera åtgärder så att du kan utföra andra uppgifter med utlösarutdata.
Om du till exempel vill filtrera händelser baserat på ett specifikt värde, till exempel en kategori, kan du lägga till ett villkor så att åtgärden Skicka händelse endast skickar de händelser som uppfyller ditt villkor.
Utlösa avsökningsbeteende
Alla Event Hubs-utlösare är utlösare för långa avsökningar. Det här beteendet innebär att när en utlösare utlöses bearbetar utlösaren alla händelser och väntar i 30 sekunder på att fler händelser ska visas i händelsehubben. Om inga händelser visas på 30 sekunder hoppas utlösaren över. Annars fortsätter utlösaren att läsa händelser tills händelsehubben är tom. Nästa utlösaravsökning sker baserat på det upprepningsintervall som du anger i utlösarens egenskaper.
Om utlösaren till exempel har konfigurerats med fyra partitioner kan den här fördröjningen ta upp till två minuter innan utlösaren har slutfört avsökningen av alla partitioner. Om inga händelser tas emot inom den här fördröjningen hoppas utlösarkörningen över. Annars fortsätter utlösaren att läsa händelser tills händelsehubben är tom. Nästa utlösaravsökning sker baserat på det upprepningsintervall som du anger i utlösarens egenskaper.
Om du känner till de specifika partitioner där meddelandena visas kan du uppdatera utlösaren till att bara läsa händelser från den eller de partitionerna genom att ange utlösarens högsta och minsta partitionsnycklar. Mer information finns i avsnittet Lägg till Event Hubs-utlösare .
Beteende för utlösarkontrollpunkt
När en Event Hubs-utlösare läser händelser från varje partition i en händelsehubb använder utlösaren sitt eget tillstånd för att underhålla information om strömförskjutningen (händelsepositionen i en partition) och partitionerna där utlösaren läser händelser.
Varje gång arbetsflödet körs läser utlösaren händelser från en partition, med början från strömförskjutningen som behålls av utlösartillståndet. I resursallokering itererar utlösaren över varje partition i händelsehubben och läser händelser i efterföljande utlösarkörningar. En enda körning hämtar händelser från en enskild partition i taget.
Utlösaren använder inte den här kontrollpunktsfunktionen i lagringen, vilket resulterar i ingen extra kostnad. Nyckelpunkten är dock att uppdatering av Event Hubs-utlösaren återställer utlösarens tillstånd, vilket kan göra att utlösaren läser händelser i början av strömmen.
Lägga till Event Hubs-åtgärd
I Azure Logic Apps följer en åtgärd utlösaren eller en annan åtgärd och utför en åtgärd i arbetsflödet. Följande steg beskriver det allmänna sättet att lägga till en åtgärd, till exempel Skicka händelse. I det här exemplet börjar arbetsflödet med en Event Hubs-utlösare som söker efter nya händelser i händelsehubben.
Öppna logikappens arbetsflöde i Logic Apps Designer, om det inte redan är öppet.
Under utlösaren eller en annan åtgärd lägger du till ett nytt steg.
Om du vill lägga till ett steg mellan befintliga steg flyttar du musen över pilen. Välj plustecknet (+) som visas och välj sedan Lägg till en åtgärd.
I åtgärdssökningsrutan anger du
event hubs. I åtgärdslistan väljer du åtgärden Med namnet Skicka händelse.
Om du uppmanas att skapa en anslutning till din händelsehubb anger du den begärda anslutningsinformationen.
I åtgärden anger du information om de händelser som du vill skicka.
Om du vill ha fler egenskaper öppnar du listan Lägg till ny parameter . Om du väljer en parameter läggs egenskapen till i åtgärden, till exempel:
Du kan till exempel skicka utdata från din Event Hubs-utlösare till en annan händelsehubb:
När du är klar klickar du på tabelldesignern Spara på kommandofältet.
Referens för anslutningsprogram
Information om alla åtgärder och annan teknisk information, till exempel egenskaper, gränser och så vidare, finns på referenssidan för Event Hubs-anslutningsappen.
Kommentar
För logikappar som finns i en integrationstjänstmiljö (ISE) använder anslutningsappens ISE-version ISE-meddelandegränserna i stället.