Anslut till en händelsehubb från arbetsflöden i Azure Logic Apps

  • Artikel
  • 7 minuter för att läsa

Anslutningsappen Azure Event Hubs hjälper dig att ansluta dina logikapparbetsflöden till event hubs i Azure. Du kan sedan få dina arbetsflöden att övervaka och hantera händelser som skickas till en händelsehubb. Arbetsflödet kan till exempel kontrollera, skicka och ta emot händelser från din händelsehubb. Den här artikeln innehåller en kom 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

Alla åtgärder och annan teknisk information, till exempel egenskaper, begränsningar och så vidare, finns på Event Hubs-anslutningsappens referenssida.

Anteckning

För logikappar som finns i en Integration Service Environment (ISE)använder anslutningsappens ISE-version ISE-meddelandebegränsningarna i stället.

Förutsättningar

Kontrollera behörigheter och hämta anslutningssträngen

Kontrollera att arbetsflödet kan komma åt händelsehubben genom att kontrollera dina behörigheter och sedan hämta anslutningssträngen för händelsehubbens namnområde.

  1. I den Azure Portalgår du till Event Hubs namnområdet, inte en specifik händelsehubb.

  2. Välj Principer för delad åtkomst under Inställningar på namnområdesmenyn. I kolumnen Anspråk kontrollerar du att du har minst hantera-behörigheter för det namnområdet.

    Skärmbild som visar Azure Portal, Event Hubs namnområde och "Hantera" behörigheter som visas i kolumnen "Anspråk".

  3. Om du senare vill ange anslutningsinformationen manuellt hämtar du anslutningssträngen för händelsehubbens namnområde.

    1. I kolumnen Princip väljer du RootManageSharedAccessKey.

    2. Hitta primärnyckelns anslutningssträng. Kopiera och spara anslutningssträngen för senare användning.

      Skärmbild som visar den primära nyckelns anslutningssträng med kopieringsknappen vald.

      Tips

      Kontrollera att anslutningssträngen inte har parametern för att bekräfta om anslutningssträngen är associerad Event Hubs namnområdet eller med en specifik EntityPath händelsehubb. Om du hittar den här parametern är anslutningssträngen för en Event Hubs "entitet" och är inte rätt sträng att använda med arbetsflödet.

Skapa en händelsehubbanslutning

När du lägger till Event Hubs utlösare eller åtgärd för första gången uppmanas du att skapa en anslutning till din händelsehubb.

  1. När du uppmanas till det väljer du något av följande alternativ:

    • Ange följande anslutningsinformation:

      Egenskap Krävs Värde Beskrivning
      Anslutningsnamn Ja <anslutningsnamn> Namnet som ska skapas för anslutningen
      Event Hubs namnområde Ja <event-hubs-namespace> Välj den Event Hubs namnrymd som du vill använda.

    • Om du vill ange den tidigare sparade anslutningssträngen manuellt väljer du Ange anslutningsinformation manuellt. Lär dig hur du hittar anslutningssträngen.

  2. Välj den Event Hubs princip som ska användas, om den inte redan är markerad, och välj sedan Skapa.

    Skärmbild som visar den angivna anslutningsinformationen med "Skapa" valt.

  3. När du har skapat anslutningen fortsätter du med Lägg till en Event Hubs utlösare eller Lägg till en Event Hubs å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 din händelsehubb och startar en arbetsflödeskörning när det finns nya händelser.

  1. I Logic Apps Designer öppnar du ditt tomma logikapparbetsflöde, om det inte redan är öppet.

  2. I åtgärdssökrutan anger du event hubs . I listan med utlösare väljer du utlösaren med namnet When events are available in Event Hub.

    Välj utlösare

  3. Om du uppmanas att skapa en anslutning till din händelsehubb anger du den begärda anslutningsinformationen.

  4. I utlösaren anger du information om den händelsehubb som du vill övervaka, till exempel:

    Egenskap Krävs Beskrivning
    Namn på händelsehubb Ja Namnet på den händelsehubb som du vill övervaka
    Innehållstyp Inga Händelsens innehållstyp. Standardvärdet är application/octet-stream.
    Konsumentgruppens namn Inga Namnet på den Event Hubs konsumentgrupp som ska användas för att läsa händelser. Om inget anges används standardkonsumentgruppen.
    Maximalt antal händelser Inga Maximalt antal 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 Tidsenhet 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 egenskapen till i utlösaren, till exempel:

    Egenskaper för utlösare

    Fler egenskaper

    Egenskap Krävs Beskrivning
    Innehållsschema Inga JSON-innehållsschemat för händelserna som ska läsas från din händelsehubb. Om du till exempel anger innehållsschemat kan du utlösa arbetsflödet för endast de händelser som matchar schemat.
    Minsta partitionsnyckel Inga Ange det minsta partitions-ID som ska läsas. Som standard läses alla partitioner.
    Maximal partitionsnyckel Inga Ange det maximala partitions-ID som ska läsas. Som standard läses alla partitioner.
    Tidszon Inga 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 Inga Ange en starttid i det här formatet:

    YYYY-MM-DDThh:mm:ss om du väljer en tidszon

    - eller -

    YYYY-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.

  5. När du är klar väljer du Spara i designerverktygsfältet.

  6. 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 visst 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ång avsökning. Det här beteendet innebär att när en utlösare utlöses bearbetar utlösaren alla händelser och väntar 30 sekunder på att fler händelser ska visas i din händelsehubb. Om inga händelser visas inom 30 sekunder hoppas utlösaren över. Annars fortsätter utlösaren att läsa händelser tills din händelsehubb är tom. Nästa utlösarsökning sker baserat på upprepningsintervallet som du anger i utlösarens egenskaper.

Om utlösaren till exempel har ställts in med fyra partitioner kan fördröjningen ta upp till två minuter innan utlösaren slutför avsökning 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 din händelsehubb är tom. Nästa utlösarsökning sker baserat på upprepningsintervallet som du anger i utlösarens egenskaper.

Om du känner till de specifika partitionerna där meddelandena visas kan du uppdatera utlösaren så att den läser händelser endast från den här eller de partitionerna genom att ange utlösarens högsta och lägsta 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, utlöser utlösaren användare sitt eget tillstånd för att underhålla information om strömförskjutningen (händelsepositionen i en partition) och de partitioner som utlösaren läser händelser från.

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. Med resursallokering itererar utlösaren över varje partition i händelsehubben och läser händelser i efterföljande utlösarkörningar. En enskild körning hämtar händelser från en enda partition i taget.

Utlösaren använder inte den här kontrollpunktskapaciteten i lagringen, vilket ger 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 dataströmmen.

Lägga till Event Hubs-åtgärd

I Azure Logic Apps följer en åtgärd utlösaren eller någon 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 din händelsehubb.

  1. I Logic Apps Designer öppnar du logikappens arbetsflöde, om det inte redan är öppet.

  2. Lägg till ett nytt steg under utlösaren eller en annan åtgärd.

    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.

  3. I åtgärdssökrutan anger du event hubs . I åtgärdslistan väljer du åtgärden Skicka händelse.

    Välj åtgärden "Skicka händelse"

  4. Om du uppmanas att skapa en anslutning till din händelsehubb anger du den begärda anslutningsinformationen.

  5. I åtgärden anger du information om de händelser som du vill skicka.

    Egenskap Krävs Beskrivning
    Namn på händelsehubb Ja Den händelsehubb där du vill skicka händelsen
    Innehåll Inga Innehållet för den händelse som du vill skicka
    Egenskaper Inga De appegenskaper och värden som ska skickas
    Partitionsnyckel Inga Partitions-ID:t för vart händelsen ska skickas

    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:

    Välj händelsehubbens namn och ange händelseinnehåll

    Du kan till exempel skicka utdata från din Event Hubs till en annan händelsehubb:

    Exempel på att skicka händelse

  6. När du är klar väljer du Spara i designerverktygsfältet.

Referens för anslutningsapp

Alla åtgärder och annan teknisk information, till exempel egenskaper, begränsningar och så vidare, finns på Event Hubs-anslutningsappens referenssida.

Anteckning

För logikappar som finns i en Integration Service Environment (ISE)använder anslutningsappens ISE-version ISE-meddelandebegränsningarna i stället.

Nästa steg