Odesílání souvisejících zpráv v daném pořadí pomocí sekvenčního konvoje v Azure Logic Apps s Azure Service Bus

Platí pro: Azure Logic Apps (Consumption)

Pokud potřebujete odesílat korelované zprávy v určitém pořadí, můžete při používání Azure Logic Apps pomocí konektoru Azure Service Bus postupovat podle sekvenčního vzoru konvoje. Korelované zprávy mají vlastnost, která definuje vztah mezi těmito zprávami, například ID relace ve službě Service Bus.

Předpokládejme například, že máte 10 zpráv pro relaci s názvem Session 1 a máte 5 zpráv pro relaci s názvem "Session 2", které se odesílají do stejné fronty služby Service Bus. Můžete vytvořit aplikaci logiky, která zpracovává zprávy z fronty, aby se všechny zprávy z relace 1 zpracovávaly jediným spuštěním triggeru a všechny zprávy z relace 2 se zpracovávají dalším spuštěním triggeru.

Tento článek ukazuje, jak vytvořit aplikaci logiky, která tento model implementuje pomocí šablony relací služby Service Bus pomocí šablony korelované doručení v pořadí. Tato šablona definuje pracovní postup aplikace logiky, který začíná triggerem konektoru Service Bus Při přijetí zprávy ve frontě (náhled uzamčení), který přijímá zprávy z fronty Service Bus. Tady jsou základní kroky, které tato aplikace logiky provádí:

• Inicializace relace na základě zprávy, že trigger čte z fronty služby Service Bus.

• Během aktuálního spuštění pracovního postupu můžete číst a zpracovávat všechny zprávy ze stejné relace ve frontě.

Pokud chcete zkontrolovat soubor JSON této šablony, přečtěte si téma GitHub: service-bus-sessions.json.

Další informace najdete v tématu Sekvenční vzor konvoje – Vzory návrhu cloudu architektury Azure.

Požadavky

• Předplatné Azure. Pokud předplatné nemáte, zaregistrujte si bezplatný účet Azure.

• Obor názvů služby Service Bus a fronta služby Service Bus, což je entita zasílání zpráv, kterou použijete v aplikaci logiky. Tyto položky a vaše aplikace logiky musí používat stejné předplatné Azure. Při vytváření fronty se ujistěte, že jste vybrali možnost Povolit relace . Pokud tyto položky nemáte, zjistěte , jak vytvořit obor názvů služby Service Bus a frontu.

  Důležité

  Při výběru triggeru i akce se stejným typem konektoru používejte upozornění a používejte je k práci se stejnou entitou, jako je například fronta zasílání zpráv nebo odběr tématu. Tato kombinace může vytvořit nekonečnou smyčku, což vede k tomu, že aplikace logiky, která nikdy nekončí.

• Základní znalosti o vytváření aplikací logiky Pokud s Azure Logic Apps začínáte, vyzkoušejte rychlý start, který vytvoří ukázkový pracovní postup aplikace logiky Consumption ve službě Azure Logic Apps s více tenanty.

Kontrola přístupu k oboru názvů služby Service Bus

Pokud si nejste jistí, jestli vaše aplikace logiky má oprávnění pro přístup k vašemu oboru názvů služby Service Bus, ověřte tato oprávnění.

1. Přihlaste se k portálu Azure. Vyhledejte a vyberte obor názvů služby Service Bus.

2. V nabídce oboru názvů v části Nastavení vyberte Zásady sdíleného přístupu. V části Deklarace identity zkontrolujte, jestli máte oprávnění Spravovat pro tento obor názvů.

   

3. Teď získejte připojovací řetězec pro váš obor názvů služby Service Bus. Tento řetězec můžete později použít při vytváření připojení k oboru názvů z aplikace logiky.

   1. V podokně Zásady sdíleného přístupu v části Zásady vyberte RootManageSharedAccessKey.

   2. Vedle primárního připojovací řetězec vyberte tlačítko kopírovat. Uložte připojovací řetězec pro pozdější použití.

      

   Tip

   Pokud chcete ověřit, jestli je váš připojovací řetězec přidružený k oboru názvů služby Service Bus nebo entitě zasílání zpráv, jako je například fronta, vyhledejte parametr v připojovací řetězecEntityPath. Pokud tento parametr najdete, připojovací řetězec je určená pro konkrétní entitu a nejedná se o správný řetězec pro použití s vaší aplikací logiky.

Vytvoření aplikace logiky

V této části vytvoříte aplikaci logiky pomocí šablony relací služby Service Bus, která zahrnuje trigger a akce pro implementaci tohoto vzoru pracovního postupu pomocí šablony relace korelace v pořadí. Vytvoříte také připojení k oboru názvů služby Service Bus a zadáte název fronty služby Service Bus, kterou chcete použít.

1. Na webu Azure Portal vytvořte prázdnou aplikaci logiky. Na domovské stránce Azure vyberte Vytvořit aplikaci logiky integrace>prostředků>.

2. Po zobrazení galerie šablon se posuňte za video a části běžných triggerů. V části Šablony vyberte šablonu, korelovaná doručení v objednávce pomocí relací služby Service Bus.

   

3. Jakmile se zobrazí potvrzovací pole, vyberte Použít tuto šablonu.

4. V Návrháři aplikace logiky v obrazci Service Bus vyberte Pokračovat a pak vyberte znaménko plus (+), které se zobrazí v obrazci.

   

5. Teď vytvořte připojení ke službě Service Bus tak, že zvolíte některou z těchto možností:

   • Chcete-li použít připojovací řetězec, které jste zkopírovali dříve z oboru názvů služby Service Bus, postupujte takto:

     1. Vyberte Ručně zadat informace o připojení.

     2. Jako název připojení zadejte název připojení. Jako připojovací řetězec vložte připojovací řetězec oboru názvů a vyberte Vytvořit, například:

        

        Tip

        Pokud tento připojovací řetězec nemáte, zjistěte, jak najít a zkopírovat obor názvů služby Service Bus připojovací řetězec.

   • Pokud chcete vybrat obor názvů služby Service Bus z aktuálního předplatného Azure, postupujte takto:

     1. Jako název připojení zadejte název připojení. Jako obor názvů služby Service Bus vyberte obor názvů služby Service Bus, například:

        

     2. Až se zobrazí další podokno, vyberte zásadu služby Service Bus a vyberte Vytvořit.

        

6. Až budete hotovi, vyberte Pokračovat.

   Návrhář aplikace logiky teď zobrazuje korelované doručování v pořadí pomocí šablony relací služby Service Bus, která obsahuje předem naplněný pracovní postup s triggerem a akcemi, včetně dvou oborů, které implementují zpracování chyb, které se řídí vzorem Try-Catch .

Teď můžete získat další informace o triggeru a akcích v šabloně, nebo můžete přejít k zadání hodnot šablony aplikace logiky.

Souhrn šablon

Tady je pracovní postup nejvyšší úrovně ve sbaleném doručování v objednávce pomocí šablony relací služby Service Bus při sbalení podrobností :

Název	Popis
When a message is received in a queue (peek-lock)	Na základě zadaného opakování tato aktivační událost služby Service Bus zkontroluje zadanou frontu služby Service Bus pro všechny zprávy. Pokud ve frontě existuje zpráva, aktivuje se trigger, který vytvoří a spustí instanci pracovního postupu. Výraz peek-lock znamená, že trigger odešle požadavek na načtení zprávy z fronty. Pokud zpráva existuje, trigger načte a zamkne zprávu tak, aby se v této zprávě neprodá žádné další zpracování, dokud nevyprší doba uzamčení. Podrobnosti získáte inicializací relace.
Init isDone	Tato akce inicializace proměnné vytvoří logickou proměnnou, která je nastavená na false a označuje, kdy jsou splněny následující podmínky: – Žádné další zprávy v relaci nejsou k dispozici ke čtení. – Zámek relace už není potřeba obnovit, aby se aktuální instance pracovního postupu dokončila. Podrobnosti najdete v tématu Inicializace relace.
Try	Tato akce oboru obsahuje akce, které se spustí pro zpracování zprávy. Pokud dojde k problému v Try oboru, následná Catch akce Oboru tento problém zpracuje. Další informace najdete v oboru Try.
Catch	Tato akce oboru obsahuje akce, které se spustí, pokud dojde k problému v předchozím Try oboru. Další informace naleznete v tématu "Catch".

Rozsah Try

Tady je tok nejvyšší úrovně v akci oboru, Try když jsou podrobnosti sbalené:

Název	Popis
Send initial message to topic	Tuto akci můžete nahradit libovolnou akcí, kterou chcete zpracovat první zprávu z relace ve frontě. ID relace určuje relaci. Pro tuto šablonu odešle akce služby Service Bus první zprávu do tématu služby Service Bus. Podrobnosti najdete v tématu Zpracování počáteční zprávy.
(paralelní větev)	Tato paralelní akce větve vytvoří dvě cesty: - Větev č. 1: Pokračujte ve zpracování zprávy. Další informace najdete v tématu Větev č. 1: Dokončení počáteční zprávy ve frontě. – Větev č. 2: Pokud se něco nepovede, opusťte zprávu a uvolněte vyzvednutí spuštěním jiné aktivační události. Další informace najdete v tématu Větev č. 2: Opuštění počáteční zprávy z fronty. Obě cesty se připojují později v relaci Zavřít ve frontě a úspěšné akce popsané v dalším řádku.
Close a session in a queue and succeed	Tato akce služby Service Bus se připojí k dříve popsaným větvím a ukončí relaci ve frontě po některé z následujících událostí: – Pracovní postup dokončí zpracování dostupných zpráv ve frontě. – Pracovní postup opouští počáteční zprávu, protože se něco nepovedlo. Podrobnosti najdete v tématu Zavření relace ve frontě a úspěšné.

Větev č. 1: Dokončení počáteční zprávy ve frontě

Název	Popis
Complete initial message in queue	Tato akce služby Service Bus označí úspěšně načtenou zprávu jako dokončenou a odebere zprávu z fronty, aby se zabránilo opětovnému zpracování. Podrobnosti najdete v tématu Zpracování počáteční zprávy.
While there are more messages for the session in the queue	Tato smyčka Until pokračuje v získávání zpráv, zatímco zprávy existují nebo dokud nepřejde jedna hodina. Další informace o akcích v této smyčce najdete v tématu Zatímco relace ve frontě obsahuje více zpráv.
Set isDone = true	Pokud neexistují žádné další zprávy, nastaví se tato proměnná akce isDone na truehodnotu .
Renew session lock until cancelled	Tato smyčka Until zajišťuje, že zámek relace je v této aplikaci logiky uložen, zatímco zprávy existují nebo dokud nepřejde jedna hodina. Další informace o akcích v této smyčce naleznete v tématu Obnovení zámku relace, dokud se nezruší.

Větev č. 2: Opuštění počáteční zprávy z fronty

Pokud akce, která zpracovává první zprávu, selže, akce Service Bus, opuštění počáteční zprávy z fronty, uvolní zprávu pro jinou instanci pracovního postupu, která se spustí pro vyzvednutí a zpracování. Podrobnosti najdete v tématu Zpracování počáteční zprávy.

Rozsah "Catch"

Pokud akce v oboru selžou Try , aplikace logiky musí relaci přesto zavřít. Akce Catch oboru se spustí, když Try má akce oboru za následek stav, Failed, Skipped, nebo TimedOut. Obor vrátí chybovou zprávu, která obsahuje ID relace, ve které došlo k problému, a ukončí aplikaci logiky.

Tady je tok nejvyšší úrovně v akci oboru, Catch když jsou podrobnosti sbalené:

Název	Popis
Close a session in a queue and fail	Tato akce služby Service Bus zavře relaci ve frontě, aby zámek relace nezůstal otevřený. Podrobnosti najdete v tématu Zavření relace ve frontě a selhání.
Find failure msg from 'Try' block	Tato akce filtrovat pole vytvoří pole ze vstupů a výstupy ze všech akcí uvnitř Try oboru na základě zadaných kritérií. V tomto případě tato akce vrátí výstupy z akcí, které způsobily Failed stav. Podrobnosti najdete v tématu Vyhledání chyby msg z bloku Try.
Select error details	Tato akce Vybrat vytvoří pole obsahující objekty JSON na základě zadaných kritérií. Tyto objekty JSON jsou vytvořeny z hodnot v poli vytvořeném předchozí akcí . Find failure msg from 'Try' block V tomto případě tato akce vrátí pole obsahující objekt JSON vytvořený z podrobností o chybě vrácených z předchozí akce. Podrobnosti najdete v tématu Výběr podrobností o chybě.
Terminate	Tato akce Ukončit zastaví spuštění pracovního postupu, zruší všechny probíhající akce, přeskočí všechny zbývající akce a vrátí zadaný stav, ID relace a výsledek chyby z Select error details akce. Podrobnosti najdete v tématu Ukončení aplikace logiky.

Dokončení šablony

Pokud chcete zadat hodnoty triggeru a akcí v korelovaném doručení v pořadí pomocí šablony relací služby Service Bus, postupujte takto. Před uložením aplikace logiky musíte zadat všechny požadované hodnoty, které jsou označené hvězdičkou (*).

Inicializace relace

• Pro trigger Při přijetí zprávy ve frontě (náhled-zámek) zadejte tyto informace, aby šablona mohla inicializovat relaci pomocí vlastnosti ID relace, například:

  

  Poznámka:

  Zpočátku je interval dotazování nastavený na tři minuty, aby aplikace logiky neběží častěji, než očekáváte, a výsledkem byly neočekávané poplatky za fakturaci. V ideálním případě nastavte interval a frekvenci na 30 sekund, aby se aplikace logiky aktivovala okamžitě, když přijde zpráva.

  Vlastnost	Požadováno pro tento scénář	Hodnota	Popis
  Název fronty	Ano	<queue-name>	Název dříve vytvořené fronty služby Service Bus. V tomto příkladu se používá "Fabrikam-Service-Bus-Queue".
  Typ fronty	Ano	Hlavní	Vaše primární fronta služby Service Bus
  ID relace	Ano	Další dostupná	Tato možnost získá relaci pro každé spuštění triggeru na základě ID relace ze zprávy ve frontě služby Service Bus. Relace je také uzamčená, aby žádná jiná aplikace logiky nebo jiný klient mohly zpracovávat zprávy související s touto relací. Následné akce pracovního postupu zpracovávají všechny zprávy přidružené k dané relaci, jak je popsáno dále v tomto článku. Tady jsou další informace o dalších možnostech ID relace: - Žádná: Výchozí možnost, která vede k žádným relacím a nelze ji použít k implementaci sekvenčního vzoru konvoje. - Zadejte vlastní hodnotu: Tuto možnost použijte, pokud znáte ID relace, které chcete použít, a vždy chcete spustit aktivační událost pro toto ID relace. Poznámka: Konektor Service Bus může uložit omezený počet jedinečných relací najednou z Azure Service Bus do mezipaměti konektoru. Pokud počet relací překročí tento limit, staré relace se z mezipaměti odeberou. Další informace najdete v tématu Exchange zprávy v cloudu pomocí Azure Logic Apps a Azure Service Bus.
  Interval	Ano	<počet intervalů>	Početčasových
  Četnost	Ano	Sekunda, minuta, hodina, den, týden nebo měsíc	Jednotka času pro opakování, která se má použít při kontrole zprávy. Tip: Chcete-li přidat časové pásmo nebo čas spuštění, vyberte tyto vlastnosti v seznamu Přidat nový parametr .

  Další informace o triggeru najdete v tématu Service Bus – Při přijetí zprávy ve frontě (náhled uzamčení). Aktivační událost vypíše ServiceBusMessage.

Po inicializaci relace pracovní postup pomocí akce Inicializovat proměnnou vytvoří logickou proměnnou, která je původně nastavena false a indikuje, kdy jsou splněny následující podmínky:

• Žádné další zprávy v relaci nejsou k dispozici ke čtení.

• Zámek relace už není potřeba obnovit, aby se aktuální instance pracovního postupu dokončila.

V dalším kroku v bloku Try pracovní postup provádí akce na první přečtené zprávě.

Zpracování počáteční zprávy

První akcí je zástupná akce služby Service Bus, odeslání počáteční zprávy do tématu, kterou můžete nahradit jakoukoli jinou akcí, kterou chcete zpracovat první zprávu z relace ve frontě. ID relace určuje relaci, ze které zpráva pochází.

Zástupná akce služby Service Bus odešle první zprávu do tématu služby Service Bus určeného vlastností ID relace. Tímto způsobem všechny zprávy přidružené ke konkrétní relaci přejdou do stejného tématu. Všechny vlastnosti ID relace pro následné akce v této šabloně používají stejnou hodnotu ID relace.

1. V akci Service Bus zadejte počáteční zprávu ve frontě, zadejte název fronty služby Service Bus a ponechte všechny ostatní výchozí hodnoty vlastností v akci.

   

2. V akci Service Bus opusťte počáteční zprávu z fronty, zadejte název fronty služby Service Bus a ponechte v akci všechny ostatní výchozí hodnoty vlastností.

   

Dále zadáte potřebné informace pro akce, které se řídí počáteční zprávou Dokončení v akci fronty . Začnete s akcemi ve smyčce fronty , zatímco existuje více zpráv pro relaci.

Zatímco pro relaci ve frontě existuje více zpráv

Tato smyčka Dokud smyčka nespustí tyto akce, zatímco zprávy existují ve frontě nebo do uplynutí jedné hodiny. Pokud chcete změnit časový limit smyčky, upravte hodnotu vlastnosti časového limitu smyčky.

• Získejte další zprávy z fronty, zatímco zprávy existují.

• Zkontrolujte počet zbývajících zpráv. Pokud zprávy stále existují, pokračujte ve zpracování zpráv. Pokud neexistují žádné další zprávy, pracovní postup nastaví proměnnou isDone na truea ukončí smyčku.

1. V akci Service Bus zadejte další zprávy z relace a zadejte název fronty služby Service Bus. V opačném případě ponechte všechny ostatní výchozí hodnoty vlastností v akci.

   Poznámka:

   Ve výchozím nastavení je maximální počet zpráv nastaven na 175, ale tento limit je ovlivněn velikostí zprávy a vlastností maximální velikosti zprávy ve službě Service Bus. Další informace najdete v tématu Velikost zprávy pro frontu.

   

   V dalším kroku se pracovní postup rozdělí do těchto paralelních větví:

   • Pokud při kontrole dalších zpráv dojde k chybě nebo selhání, nastavte proměnnou isDone na truehodnotu .

   • Pokud jsme dostali nějaké podmínky, zkontroluje, jestli je počet zbývajících zpráv nula. Pokud existují false a další zprávy, pokračujte ve zpracování. Pokud platí a neexistují žádné další zprávy, pracovní postup nastaví proměnnou isDone na true.

   

   V části If false zpracovává smyčka For each message in first-in, first-out order (FIFO). V nastavení smyčky je nastavení Řízení souběžnosti nastaveno na 1, takže se současně zpracuje jenom jedna zpráva.

   

2. V případě akcí služby Service Bus dokončete zprávu ve frontě a opusťte zprávu ve frontě, zadejte název fronty služby Service Bus.

   

   Po dokončení relace ve frontě je k dispozici více zpráv, pracovní postup nastaví proměnnou isDone na true.

V dalším kroku zadáte potřebné informace pro akce v uzamčení relace obnovení, dokud se nezruší smyčka .

Prodloužení platnosti zámku relace do zrušení

Tato smyčka Until zajišťuje, že zámek relace je v této aplikaci logiky uložen, zatímco zprávy existují ve frontě nebo dokud jedna hodina nepřejde spuštěním těchto akcí. Pokud chcete změnit časový limit smyčky, upravte hodnotu vlastnosti časového limitu smyčky.

• Zpoždění po dobu 25 sekund nebo doba kratší než doba časového limitu uzamčení pro zpracovávanou frontu. Nejmenší doba trvání zámku je 30 sekund, takže je dostatečná výchozí hodnota. Počet spuštění smyčky ale můžete optimalizovat odpovídajícím způsobem.

• Zkontrolujte, jestli isDone je proměnná nastavená na truehodnotu .

  • Pokud isDone je nastavená hodnota true, pracovní postup stále zpracovává zprávy, takže pracovní postup obnoví zámek relace ve frontě a znovu zkontroluje podmínku smyčky.

    Název fronty služby Service Bus musíte zadat v akci Service Bus a obnovit zámek relace ve frontě.

  • Pokud isDone je nastavená hodnota true, pracovní postup neprodlouží zámek relace ve frontě a ukončí smyčku.

  

Prodloužení zámku relace ve frontě

Tato akce služby Service Bus obnoví zámek relace ve frontě, zatímco pracovní postup stále zpracovává zprávy.

• V akci Service Bus zamkněte relaci ve frontě a zadejte název fronty služby Service Bus.

  

Dále zadáte potřebné informace pro akci Service Bus, zavřete relaci ve frontě a uspějete.

Zavření relace ve frontě a úspěšné

Tato akce služby Service Bus zavře relaci ve frontě, jakmile pracovní postup dokončí zpracování všech dostupných zpráv ve frontě, nebo pracovní postup počáteční zprávu opustí.

• V akci Service Bus zavřete relaci ve frontě a úspěšně zadejte název fronty služby Service Bus.

  

Následující části popisují akce v Catch této části, které zpracovávají chyby a výjimky, ke kterým dochází ve vašem pracovním postupu.

Zavření relace ve frontě a selhání

Tato akce služby Service Bus se vždy spustí jako první akce v Catch oboru a zavře relaci ve frontě.

• V akci Service Bus zavřete relaci ve frontě a selžte, zadejte název fronty služby Service Bus.

  

Dále pracovní postup vytvoří pole, které obsahuje vstupy a výstupy ze všech akcí v Try oboru, aby aplikace logiky získala přístup k informacím o chybě nebo selhání, ke které došlo.

Vyhledání chyby z bloku Try

Tato akce pole filtru vytvoří matici, která má vstupy a výstupy ze všech akcí uvnitř Try oboru na základě zadaných kritérií pomocí result() funkce. V tomto případě tato akce vrátí výstupy z akcí, které mají Failed stav pomocíequals() funkce a item() funkce.

Tady je definice JSON pro tuto akci:

"Find_failure_msg_from_'Try'_block": {
   "inputs": {
      "from": "@Result('Try')",
      "where": "@equals(item()['status'], 'Failed')"
   },
   "runAfter": {
      "Close_the_session_in_the_queue_and_fail": [
         "Succeeded"
      ]
   },
   "type": "Query"
},

Dále pracovní postup vytvoří pole s objektem JSON, který obsahuje informace o chybě v poli vrácené z Find failure msg from 'Try' block akce.

Výběr podrobností o chybě

Tato akce Vybrat vytvoří pole obsahující objekty JSON na základě vstupního pole, které je výstupem z předchozí akce. Find failure msg from 'Try' block Konkrétně tato akce vrátí pole, které má pouze zadané vlastnosti pro každý objekt v poli. V tomto případě pole obsahuje název akce a vlastnosti výsledku chyby.

Tady je definice JSON pro tuto akci:

"Select_error_details": {
   "inputs": {
      "from": "@body('Find_failure_msg_from_''Try''_block')[0]['outputs']",
      "select": {
         "action": "@item()['name']",
         "errorResult": "@item()"
      }
   },
   "runAfter": {
      "Find_failure_msg_from_'Try'_block": [
         "Succeeded"
      ]
   },
   "type": "Select"
},

V dalším kroku pracovní postup zastaví spuštění aplikace logiky a vrátí stav spuštění spolu s dalšími informacemi o chybě nebo selhání, ke které došlo.

Ukončení spuštění aplikace logiky

Tato akce Ukončit zastaví spuštění aplikace logiky a vrátí Failed se jako stav spuštění aplikace logiky spolu s ID relace a výsledkem chyby z Select error details akce.

Tady je definice JSON pro tuto akci:

"Terminate": {
   "description": "This Failure Termination only runs if the Close Session upon Failure action runs - otherwise the LA will be terminated as Success",
   "inputs": {
      "runError": {
         "code": "",
         "message": "There was an error processing messages for Session ID @{triggerBody()?['SessionId']}. The following error(s) occurred: @{body('Select_error_details')['errorResult']}"
         },
         "runStatus": "Failed"
      },
      "runAfter": {
         "Select_error_details": [
            "Succeeded"
         ]
      },
      "type": "Terminate"
   }
},

Uložení a spuštění aplikace logiky

Po dokončení šablony teď můžete aplikaci logiky uložit. Na panelu nástrojů návrháře vyberte Uložit.

Pokud chcete otestovat aplikaci logiky, odešlete zprávy do fronty služby Service Bus.

Další kroky

• Další informace o triggerech a akcích konektoru Service Bus