Model prostředků Azure Stream Analytics

Azure Stream Analytics je plně spravovaná platforma jako služba (PaaS) pro zpracování datových proudů. Tento článek popisuje model prostředků pro Stream Analytics tím, že představuje koncept clusteru Stream Analytics, úlohy a komponent úlohy.

Úloha Stream Analytics

Úloha streamové analýzy je základní jednotkou Stream Analytics, která umožňuje definovat a spouštět logiku zpracování datových proudů. Úloha se skládá ze 3 hlavních komponent:

• Vstup
• Výstup
• Dotaz

Vstup

Úloha může mít jeden nebo více vstupů pro průběžné čtení dat. Těmito streamovanými vstupními zdroji dat může být Azure Event Hubs, Azure IoT Hub nebo Azure Storage. Stream Analytics také podporuje čtení statických nebo pomalých vstupních dat (označovaných jako referenční data), která se často používají k obohacení streamovaných dat. Přidání těchto vstupů do úlohy je operace s nulovým kódem.

Výstup

Úloha může mít jeden nebo více výstupů pro průběžné zápis dat do. Stream Analytics podporuje 12 různých výstupních jímek, mezi které patří Azure SQL Database, Azure Data Lake Storage, Azure Cosmos DB, Power BI a další. Přidání těchto výstupů do úlohy je také operace s nulovým kódem.

Dotaz

Logiku zpracování datových proudů můžete implementovat tak, že do své úlohy napíšete dotaz SQL. Bohatá podpora jazyka SQL umožňuje řešit scénáře, jako je analýza složitých hodnot JSON, filtrování hodnot, agregace výpočtů, provádění spojení a ještě pokročilejší případy použití, jako je geoprostorová analýza a detekce anomálií. Tento jazyk SQL můžete také rozšířit pomocí uživatelem definovaných funkcí Jazyka JavaScript (UDF) a agregací definovaných uživatelem (UDA). Stream Analytics vám také umožňuje snadno upravit zpožděné a mimo pořadí události prostřednictvím jednoduchých konfigurací v nastavení vaší úlohy. Můžete také zvolit provedení dotazu na základě času příchodu vstupní události na vstupním místě nebo času vygenerování události ve zdrojovém místě.

Spuštění úlohy

Jakmile úlohu vytvoříte tak, že nakonfigurujete vstupy, výstup a dotaz, můžete úlohu spustit zadáním počtu jednotek streamování. Jakmile se úloha spustí, přejde do stavu Spuštěno a zůstane v něm, dokud se explicitně nezastaví nebo narazí na neopravitelnou chybu. Když je úloha ve spuštěném stavu, průběžně načítá data z vašich vstupních zdrojů, spustí logiku dotazu, která generuje výsledky, které se zapisují do výstupních jímek s kompletní latencí milisekund.

Po spuštění úlohy se služba Stream Analytics postará o kompilaci dotazu a přiřadí určité množství výpočetních prostředků a paměti na základě počtu jednotek streamování nakonfigurovaných ve vaší úloze. Nemusíte se starat o žádnou základní infrastrukturu jako údržbu clusteru, opravy zabezpečení, protože se o to platforma postará automaticky. Při spouštění úloh v SKU Standard se vám účtují jednotky streamování pouze při spuštění úlohy.

Stream Analytics cluster

Ve výchozím nastavení běží úlohy Stream Analytics ve standardním prostředí s více tenanty, které tvoří Standard SKU. Stream Analytics také poskytuje vyhrazenou skladovou položku, kde můžete zřídit celý cluster Stream Analytics, který patří vám. Tím získáte úplnou kontrolu nad tím, které úlohy běží ve vašem clusteru. Minimální velikost clusteru Stream Analytics je 12 jednotek streamování a po zřízení se vám účtuje celá kapacita clusteru. Další informace o výhodách clusterů Stream Analytics a o tom, kdy je používat.

Další kroky

Zjistěte, jak spravovat Azure Stream Analytics a další koncepty:

• Vytvoření řešení pro detekci podvodů pomocí Stream Analytics
• Přehled vstupů
• Přehled výstupů
• Vývoj dotazu