Zdieľať cez

Smerovanie streamov údajov na základe obsahu v streamoch udalostí služby Fabric (Preview)

  • Článok

V tomto článku sa dozviete, ako smerovať udalosti na základe obsahu v streamoch udalostí služby Microsoft Fabric.

Teraz môžete použiť editor bez písania kódu na hlavnom plátne udalosti služby Fabric na vytvorenie zložitej logiky spracovania streamu bez nutnosti písania kódu. Táto funkcia vám umožňuje jednoduchšie prispôsobiť, transformovať a spravovať streamy údajov. Po nastavení operácií spracovania streamu môžete bez problémov odosielať streamy údajov do rôznych cieľov podľa konkrétnej schémy a streamových údajov.

Dôležité

Vylepšené možnosti streamov udalostí služby Fabric sú v súčasnosti v režime ukážky.

Podporované operácie

Tu je zoznam operácií podporovaných pri spracovaní údajov v reálnom čase:

  • Agregácia: Podporujú funkcie SUM, AVG, MIN a MAX, ktoré vykonávajú výpočty v stĺpci hodnôt a vracajú jeden výsledok.

  • Rozbalenie: Rozbaľte hodnotu poľa a vytvorte nový riadok pre každú hodnotu v poli.

  • Filter: Vyberte alebo filtrujte konkrétne riadky v streame údajov na základe podmienky.

  • Spôsob zoskupenia: Agregujte všetky údaje udalosti v určitom časovom okne s možnosťou zoskupiť jeden alebo viac stĺpcov.

  • Spravovať polia: Pridanie, odstránenie alebo zmena typu údajov poľa alebo stĺpca v streamoch údajov.

  • Zjednotenie: Pripojenie dva alebo viaceré streamy údajov so zdieľanými poľami s rovnakým názvom a typom údajov do jedného streamu údajov. Polia, ktoré sa nezhodujú, sa vynechajú.

  • Pripojiť: Kombinovanie údajov z dvoch streamov na základe zodpovedajúcej podmienky medzi nimi.

Podporované ciele

Podporované cieľové umiestnenia sú:

  • Lakehouse: Tento cieľ vám umožňuje transformovať svoje udalosti v reálnom čase pred požitím do vášho jazera. Udalosti v reálnom čase sa premenia na formát Delta Lake a potom sa uložia v určených tabuľkách lakehouse. Tento cieľ pomáha so scenármi uschovávanie údajov.

  • Databáza KQL: Toto cieľové umiestnenie vám umožňuje preniesť údaje udalosti v reálnom čase do databázy KQL, kde môžete použiť výkonný jazyk Kusto Query Language (KQL) na dotazovanie a analýzu údajov. Vďaka údajom v databáze KQL môžete získať hlbšie prehľady o údajoch udalosti a vytvárať komplexné zostavy a tabule.

  • Reflex: Tento cieľ vám umožní priamo prepojiť údaje o udalosti v reálnom čase s reflexom. Reflex je typ inteligentného agenta, ktorý obsahuje všetky informácie potrebné na pripojenie k údajom, monitorovanie podmienok a pôsobiť. Keď údaje dosiahnu určité prahové hodnoty alebo sa zhodujú s inými vzormi, Reflex automaticky podnikne príslušné kroky, ako je upozorňovanie používateľov alebo vykopnutie pracovných postupov služby Power Automate.

  • Vlastný koncový bod (bývalá vlastná aplikácia): S týmto cieľom môžete jednoducho presmerovať udalosti v reálnom čase do vlastnej aplikácie. Vďaka tomuto cieľu môžete pripojiť svoje vlastné aplikácie k eventstreamu a využívať údaje udalosti v reálnom čase. Je to užitočné, ak chcete výstup údajov v reálnom čase postúpiť k externému systému mimo služby Microsoft Fabric.

  • Stream: Toto cieľové umiestnenie predstavuje predvolený nespracovaný udalosťstream transformovaný sériou operácií, ktorá sa nazýva aj odvodený stream. Po vytvorení môžete stream zobraziť z centra v reálnom čase.

V nasledujúcom príklade je znázornené, ako môžu tri odlišné cieľové umiestnenie udalostí služby Fabric slúžiť samostatným funkciám pre jeden zdroj streamu údajov. Jedna databáza KQL je určená na ukladanie nespracovaných údajov, druhá databáza KQL je na uchovávanie filtrovaných streamov údajov a Lakehouse sa používa na ukladanie agregovaných hodnôt.

Snímka obrazovky udalostí smerovania na základe obsahu.

Ak chcete transformovať a smerovať stream údajov na základe obsahu, postupujte podľa krokov v článku Úprava a publikovanie udalostí a začnite navrhovať logiku spracovania streamu pre váš stream údajov.

Súvisiaci obsah