Výstup Azure Functions z Azure Stream Analytics

Azure Functions je bezserverová výpočetní služba, kterou můžete použít ke spouštění kódu na vyžádání, aniž byste museli explicitně zřizovat nebo spravovat infrastrukturu. Umožňuje implementovat kód, který se aktivuje událostmi, ke kterým dochází v Azure nebo partnerských službách. Díky této schopnosti Azure Functions reagovat na triggery je přirozeným výstupem pro Azure Stream Analytics. Tento výstupní adaptér umožňuje uživatelům připojit Stream Analytics ke službě Azure Functions a spustit skript nebo část kódu v reakci na různé události.

Výstup služby Azure Functions ze stream Analytics není k dispozici v Microsoft Azure provozovaném společností 21Vianet a Azure Germany (T-Systems International). Připojení ke službě Azure Functions ve virtuální síti (VNet) z úlohy Stream Analytics spuštěné v clusteru s více tenanty se také nepodporuje.

Azure Stream Analytics volá Azure Functions prostřednictvím triggerů HTTP. Výstupní adaptér Azure Functions je k dispozici s následujícími konfigurovatelnými vlastnostmi:

Název vlastnosti Description
Funkční aplikace Název vaší aplikace Azure Functions.
Funkce Název funkce ve vaší aplikaci Azure Functions.
Klíč Pokud chcete použít Azure Function z jiného předplatného, můžete tak učinit zadáním klíče pro přístup k vaší funkciji.
Maximální velikost dávky Vlastnost, která vám umožní nastavit maximální velikost pro každou výstupní dávku, která je odeslána do vaší Azure funkce. Vstupní jednotka je v bajtech. Ve výchozím nastavení je tato hodnota 262 144 bajtů (256 kB).
Maximální počet dávek Vlastnost, která vám umožní určit maximální počet událostí v každé dávce, která je odeslána do Azure Functions. Výchozí hodnota je 100.

Azure Stream Analytics očekává stav HTTP 200 z aplikace Functions pro dávky, které byly úspěšně zpracovány.

Když Azure Stream Analytics obdrží výjimku 413 (http Request Entity Too Large) z funkce Azure, zmenšuje velikost dávek, které odesílá do Azure Functions. V kódu funkce Azure použijte tuto výjimku, abyste měli jistotu, že Azure Stream Analytics neodesílá příliš velké dávky. Ujistěte se také, že maximální počet dávek a hodnoty velikosti použité ve funkci jsou konzistentní s hodnotami zadanými na portálu Stream Analytics.

Poznámka:

Během testovacího připojení Stream Analytics odešle do Azure Functions prázdnou dávku (POST), která otestuje, jestli připojení mezi těmito dvěma funkcemi funguje. Ujistěte se, že vaše aplikace Functions zpracovává prázdné dávkové požadavky, aby se zajistilo, že testovací připojení projde.

V situaci, kdy v časovém intervalu nedojde k žádnému přistání události, se negeneruje žádný výstup. Výsledkem je, že funkce computeResult není volána. Toto chování je konzistentní s integrovanými agregačními funkcemi s okny.

Partitioning

Klíč oddílu vychází z klauzule PARTITION BY v dotazu. Počet zapisovačů výstupu se řídí vstupním dělením pro plně paralelizované dotazy.

Velikost dávky výstupu

Výchozí velikost dávky je 262 144 bajtů (256 kB). Výchozí počet událostí na dávku je 100. Velikost dávky je konfigurovatelná a dá se zvětšit nebo zmenšit v možnostech výstupu Stream Analytics.

Omezení

Služba Azure Functions by měla dokončit svůj požadavek za méně než 100 sekund, protože klient HTTP vyprší po 100 sekundách. Pokud zpracování dávky dat službě Azure Functions trvá déle než 100 sekund, dojde k vypršení časového limitu, který aktivuje opakování. Výsledkem tohoto opakování můžou být duplicitní data, protože Azure Functions bude data zpracovávat znovu a potenciálně vytvoří stejný výstup, protože se mohl v předchozím požadavku částečně vygenerovat.

Ukázky kódu

Výstup služby Azure Functions se dá použít k předávání zpráv do nepodporovaných databází, jako je Redis, nebo k aktualizaci tabulek v Azure SQL.

Další kroky

  • Last updated on