Zpracování dat z centra událostí pomocí Azure Stream Analytics

  • Článek
  • 2 min ke čtení

Služba Azure Stream Analytics usnadňuje ingestování, zpracování a analýzu streamování dat z Azure Event Hubs a umožňuje efektivní přehledy, které umožňují řídit akce v reálném čase. Tato integrace vám umožní rychle vytvořit kanál analýzy v Hot-Path. Azure Portal můžete použít k vizualizaci příchozích dat a napsání dotazu Stream Analytics. Jakmile je dotaz připravený, můžete ho přesunout do produkčního prostředí jenom několika kliknutími.

Klíčové výhody

Tady jsou klíčové výhody služby Azure Event Hubs a Integrace Azure Stream Analytics:

  • Náhled dat – můžete zobrazit náhled příchozích dat z centra událostí v Azure Portal.
  • Otestujte dotaz – Připravte dotaz na transformaci a otestujte ho přímo v Azure Portal. Syntaxi jazyka dotazů naleznete v tématu Stream Analytics dokumentaci jazyka dotazů .
  • Nasazení dotazu do produkčního prostředí – dotaz můžete nasadit do produkčního prostředí vytvořením a spuštěním Azure Stream Analytics úlohy.

Koncový tok

  1. Přihlaste se k webu Azure Portal.

  2. Přejděte do oboru názvů Event Hubs a potom přejděte do centra událostí, které obsahuje příchozí data.

  3. Na stránce centrum událostí vyberte zpracovat data .

    Dlaždice zpracovat data

  4. Na dlaždici Povolit přehledy událostí v reálném čase vyberte prozkoumat .

    Vyberte Stream Analytics

  5. Zobrazí se stránka s dotazem s hodnotami, které jsou už nastavené pro následující pole:

    1. Centrum událostí jako vstup pro dotaz.

    2. ukázka SQL dotaz s příkazem select.

    3. Alias výstupu , který odkazuje na výsledky testu dotazu.

      Editor dotazů

      Poznámka

      Při prvním použití této funkce bude tato stránka požádána o vaše oprávnění k vytvoření skupiny uživatelů a zásad pro vaše centrum událostí pro zobrazení náhledu příchozích dat.

  6. V podokně Náhled vstupu vyberte vytvořit , jak je znázorněno na předchozím obrázku.

  7. Na této kartě se okamžitě zobrazí snímek nejnovějších příchozích dat.

    • Typ serializace v datech se automaticky detekuje (JSON/CSV). Můžete ji ručně změnit i na JSON/CSV/AVRO.

    • Můžete zobrazit náhled příchozích dat ve formátu tabulky nebo v nezpracovaném formátu.

    • Pokud vaše data nejsou aktuální, vyberte aktualizovat , aby se zobrazily nejnovější události.

      Tady je příklad dat ve formátu tabulky: výsledky ve formátu tabulky.

      Tady je příklad dat v nezpracovaném formátu:

      Výsledky v nezpracovaném formátu

  8. Vyberte možnost test Query a zobrazte snímek výsledků testu dotazu na kartě výsledky testu . Můžete si také stáhnout výsledky.

    Test výsledků dotazu

  9. Napište vlastní dotaz pro transformaci dat. Viz referenční informace k jazyku Stream Analytics dotazů.

  10. Až dotaz otestujete a chcete ho přesunout do produkčního prostředí, vyberte nasadit dotaz. Chcete-li nasadit dotaz, vytvořte úlohu Azure Stream Analytics, kde můžete nastavit výstup pro svou úlohu a spustit úlohu. Chcete-li vytvořit úlohu Stream Analytics, zadejte název úlohy a vyberte vytvořit.

    Vytvoření úlohy Azure Stream Analytics

    Poznámka

    Doporučujeme vytvořit skupinu příjemců a zásadu pro každou novou Azure Stream Analytics úlohu, kterou vytvoříte ze stránky Event Hubs. Skupiny uživatelů umožňují jenom pět současných čtecích zařízení, takže pokud pro každou úlohu zadáte vyhrazenou skupinu uživatelů, vyhnete se případným chybám, které by mohly vzniknout nad rámec tohoto omezení. Vyhrazená zásada vám umožní otočit klíč nebo odvolat oprávnění, aniž by to mělo vliv na jiné prostředky.

  11. Vaše úloha Stream Analytics se teď vytvoří tam, kde je váš dotaz stejný, který jste otestovali, a vstupem je vaše centrum událostí.

  12. Pro dokončení kanálu nastavte výstup dotazu a výběrem Spustit spusťte úlohu.

    Poznámka

    Před zahájením úlohy Nezapomeňte nahradit outputalias názvem výstupu, který jste vytvořili v Azure Stream Analytics.

    Nastavte výstup a spusťte úlohu.

Známá omezení

Při testování dotazu trvá načtení výsledků testů přibližně 6 sekund. Pracujeme na vylepšení výkonu testování. Pokud však dojde k nasazení v produkčním prostředí, Azure Stream Analytics bude k dispozici i sekundová latence.

Jednotky streamování

Vaše úloha Azure Stream Analytics ve výchozím nastavení má tři jednotky streamování (SUs). Chcete-li upravit toto nastavení, vyberte možnost škálovat v levé nabídce na stránce Stream Analytics úlohy v Azure Portal. Další informace o jednotkách streamování najdete v tématu pochopení a úprava jednotek streamování.

Škálování jednotek streamování

Další kroky

Další informace o Stream Analyticsch dotazech najdete v tématu Stream Analytics dotazovací jazyk .