Co je Fabric Activator?

Fabric Aktivátor je modul pro detekci událostí bez kódu, který transformuje datové proudy na automatizované akce. Automaticky aktivuje akce při zjištění konkrétních vzorů nebo podmínek ve zdrojích dat. Nepřetržitě monitoruje tyto zdroje dat s nízkou latencí (podsekundou pro bezstavová pravidla pro streamovaná data) a inicializuje akce při splnění prahových hodnot nebo zjištění konkrétních vzorů. Mezi tyto akce patří odesílání e-mailů nebo oznámení Teams, spouštění Power Automate toků nebo integrace se systémy třetích stran.

Základní architektura

Aktivátor je modul pro detekci událostí a stroj pravidel v srdci inteligentního zásobníku Fabric Real-Time. Architektura funguje jako inteligentní pozorovatel – využívá vysokorychlostní datové proudy, vyhodnocuje podmínky pravidel téměř v reálném čase a spouští automatizované podřízené akce na základě změn ve stavech událostí.

Zapadá do reaktivní architektury řízené událostmi, kde data proudí nepřetržitě a Aktivátor provádí rozhodnutí na základě stavových vyhodnocení dat událostí téměř v reálném čase.

Diagram znázorňující architekturu Fabric Activator.

  • zdroje událostí

    Aktivátor se připojuje přímo k eventstreamům, které ingestují data od různých výrobců (Azure Event Hubs, zařízení IoT, vlastních koncových bodů a dalších zdrojů). Tyto streamy slouží jako zdroj událostí a aktivátor se může přihlásit k odběru jednoho nebo více streamů událostí, aby bylo možné sledovat změny dat. Jiné zdroje událostí mohou být události z Fabric nebo Azure, nebo aktivátor naslouchající sestavě Power BI nebo řídicímu panelu v reálném čase.

  • Události a objekty

    Události jsou jednotlivé záznamy (například signál telemetrie nebo vyřazení souboru) přijaté prostřednictvím eventstreamu. Tyto události jsou seskupené do objektů na základě sdíleného identifikátoru (například všechny události ze stejného zařízení jsou seskupené pomocí device_idnebo všechny události stanice kol jsou seskupené bikepoint_idpodle ). Pravidla se pak vyhodnocují na objekt, což umožňuje jemně odstupňovanou detekci (například na senzor nebo prostředek).

  • Pravidla a podmínky

    Každý aktivátor obsahuje jedno nebo více pravidel, která se vyhodnocují nepřetržitě. Tato pravidla mohou být jednoduchá porovnání (value < threshold) nebo podmínky, které sledují změny v průběhu času, například BECOMES, DECREASES, INCREASES, EXIT RANGE nebo nepřítomnost dat (heartbeat). Aktivátor zajišťuje sledování stavu pro jednotlivé objekty, což umožňuje komplexní detekci vzorů v průběhu času.

  • Akce

    Po splnění podmínky pravidla může aktivátor aktivovat:

    • kanály, poznámkové bloky, toky dat, funkce uživatelských dat (UDF) (Preview) nebo definice úloh Sparku v Fabric.

    • Externí akce prostřednictvím Power Automate

    • Odešlete zprávu Teams jednotlivci, skupině nebo kanálu.

    • Odeslat email

  • Správa výstrah a testování pravidel

    Aktivátor poskytuje náhled a odhady dopadu před aktivací pravidel a ukazuje, jak často by pravidlo bylo spuštěno na historických datech. Tyto funkce pomáhají zabránit spamování a nadměrnému spouštění upozornění. Interně jsou přechody stavu řízeny tak, aby potlačily šum (například hodnota musí překročit prahovou hodnotu, ne jen zůstat pod ní).

  • Monitorování a řízení nákladů

    Účtují se vám pouze náklady, pokud jsou aktivátory aktivně spuštěné. Instance aktivátoru jsou přiděleny kapacitám Fabric a je lze monitorovat prostřednictvím pracovního prostoru. Protokoly runtime a telemetrie jsou k dispozici prostřednictvím streamů událostí a výstupů z kanálu.

Model nasazení

Nasaďte instance aktivátoru pro každý pracovní prostor a svázejte je s konkrétními zdroji dat. Stejný datový proud může monitorovat více aktivátorů, takže pro různé obchodní funkce můžete použít paralelní vyhodnocení pravidel. Protože je aktivátor vázaný na kapacitu, platí ceny průběžných plateb jenom v případě, že jsou pravidla aktivně spuštěná. Tento cenový model poskytuje nákladovou efektivitu pro scénáře přerušovaného zjišťování. Známá omezení najdete v tématu Omezení aktivátoru.

Integrační body v rámci Real-Time intelligence

Součást Interakce s aktivátorem
Eventstream Odesílá data v reálném čase do aktivátoru, aby bylo možné monitorovat vzory a podmínky. Vytváření výstrah a správa pravidel se také vkládají přímo do eventstreamu, takže uživatelé můžou vytvářet a spravovat pravidla v kontextu.
Aktivátor Může vytvářet nové události, jako jsou rozšířená data nebo data zařazená do kategorií, které aktivují další aktivační událost.
Kanál Cíl spouštění pravidel aktivátoru, které automatizuje následné zpracování.
Power BI Slouží jako zdroj událostí pro pravidla aktivátoru týkající se vizuálů sestav, včetně detekce řádků vizuálu tabulky. Využívá také výsledek aktivovaných kanálů nebo poznámkových bloků pro vizualizace v reálném čase.
Power Automate Automatizuje úlohy pomocí předem připravených nebo vlastních pracovních postupů při výskytu událostí.
události Fabric Poskytuje události, ke kterým dochází v rámci Fabric, jako je aktualizace sémantického modelu nebo selhání kanálu.
Notebooks Aktivátor může spustit spuštění poznámkového bloku.
Definice úlohy Sparku Aktivátor může vyvolat spuštění úlohy Spark.
Uživatelská datová funkce Aktivátor může aktivovat spuštění funkce uživatelská data (UDF) (Preview).
Datový tok Aktivátor může aktivovat spuštění toku dat, když je splněna podmínka pravidla.

Aktivátor jako orchestrátor

Chcete-li Aktivátor efektivně používat ve velkých systémech, koordinujte jeho fungování s dalšími komponentami Fabric. Optimalizujte nastavení na základě toho, kolik dat zpracováváte, kolik objektů sledujete a jak složitá jsou vaše pravidla. V této části se dozvíte, jak orchestrovat aktivátor s jinými službami a jak optimalizovat logiku detekce a chování modulu runtime pro podporu nízké latence (rychlé), nákladově efektivní automatizace ve velkém měřítku.

Aktivátor hraje ústřední roli v událostmi řízených potrubích tím, že vyhodnocuje data v okamžiku přijetí a spouští akce níže. Mezi typické vzory orchestrace patří:

Vzor Popis toku
Příjem dat → Detekce → Transformace Události proudí z eventstreamu do aktivátoru, který aktivuje kanál pro rozšiřování nebo přesouvání dat.
Příjem → Detekce → Oznámení Aktivátor spustí Power Automate k odeslání upozornění nebo aktualizaci stavu do Teams, Outlooku nebo ServiceNow.
Příjem dat → zjišťování → vyhodnocování modelu Aktivátor aktivuje poznámkový blok pro určení skóre modelu ML nebo provádění pokročilých analýz na základě anomálií v reálném čase.
Smyčka zpětné vazby s aktivátorem (plánovaná) Aktivátorem generované přehledy (například popisky citlivosti) se předávají do pravidel aktivátoru, což umožňuje sémanticky rozšířenou automatizaci.

Klíčové koncepty

Fabric Aktivátor nepřetržitě monitoruje vaše data a rychle zjistí, kdy jsou splněny podmínky, i když se data v průběhu času mění. V jádru funkce Aktivátor zpracovává události generované v reálném čase prostřednictvím eventstreamu, vyhodnocuje podmínky pravidla na logický objekt a inicializuje akce v reakci na přechody stavu.

Pomocí následujících konceptů můžete vytvářet a spouštět automatizované akce a odpovědi v nástroji Fabric Activator.

Zdroje událostí a události

Fabric Aktivátor zachází se všemi zdroji dat jako se streamy událostí. Událost představuje pozorování o stavu objektu a obvykle zahrnuje identifikátor objektu, časové razítko a hodnoty monitorovaných polí.

Události ingestované do aktivátoru pocházejí z:

  • Eventstream, který podporuje více upstreamových zdrojů (například Azure Event Hubs, IoT Hub, Blob Storage triggery). Eventstream je konkrétní typ položky v Microsoft Fabric, který umožňuje ingestovat, transformovat a směrovat události v reálném čase bez psaní kódu. Fabric Aktivátor monitoruje stream událostí a automaticky provede akci při zjištění definovaných vzorů nebo prahových hodnot. Aktivátor se také může přihlásit k odběru dvou nebo více streamů událostí, aby bylo možné sledovat změny dat. Streamy událostí se liší podle četnosti. Senzory IoT například generují události několikrát za sekundu a logistické systémy generují události sporadicky, například když se balíčky naskenují na expedičních místech.
  • Události fabricu. Například události spojené s položkami pracovního prostoru Fabric jsou samostatné události Fabric, ke kterým dochází při změnách v pracovním prostoru Fabric. Mezi tyto změny patří vytvoření, aktualizace nebo odstranění položky Fabric.
  • Azure události. Například Azure Blob Storage události se aktivují, když klient vytvoří, nahradí nebo odstraní objekt blob.
  • Obchodní události. Výstrahy můžete nastavit přímo na obchodní události, které automatizují akce, když dojde k určitým obchodním podmínkám.
  • Fabricové ontologické obchodní entity (Náhled). Pravidla je možné definovat u obchodních entit ontologie, která inicializuje výstrahy a automatizované akce, což umožňuje rozhodování o provozu na základě modelovaných dat.
  • Power BI sestava. V tomto případě jsou události pravidelnými pozorováními na základě plánu aktualizace Power BI sémantického modelu (dříve označovaného jako datová sada). K těmto pozorováním může docházet denně nebo týdně, což tvoří pomalý tok událostí. Aktivátor se také integruje se službou Power BI, aby informoval uživatele, když se ve vizuálu tabulky v publikované sestavě objeví nový řádek, což umožňuje pravidlům sledovat změny na úrovni vizuálů a aktivovat oznámení nebo následné akce.
  • Řídicí panel pro Fabric v reálném čase.

Každá událost obsahuje:

  • Časové razítko
  • Užitečné zatížení (strukturovaná nebo částečně strukturovaná data)
  • Jeden nebo více atributů používaných k identifikaci objektů (například device_id, bikepoint_id)

Objekty

V Fabric Aktivátoru se entity, které monitorujete, nazývají obchodní objekty, které můžou být fyzické nebo koncepční. Mezi příklady patří fyzické objekty, jako jsou mrazáky, vozidla, balíčky a uživatelé, a koncepční objekty, jako jsou reklamní kampaně, zákaznické účty, uživatelské relace.

Pokud chcete modelovat obchodní objekt v aktivátoru, propojíte jeden nebo více eventstreamů, vyberete sloupec, který bude sloužit jako ID objektu, a zadáte pole, která chcete považovat za vlastnosti objektu.

Instance objektu odkazuje na specifický příklad obchodního objektu, jako je například mrazák, vozidlo nebo uživatelská relace. Naproti tomu objekt obvykle odkazuje na obecnou definici nebo třídu (například mrazák jako typ). Termín populace se používá pro úplnou sadu instancí objektů, které jsou monitorovány.

Vytvoření objektu je implicitní: Aktivátor seskupuje události pomocí určeného klíče objektu. Pravidla jsou vymezena na objekty, což znamená, že veškerá logika vyhodnocení je objektově závislá a nezávislá napříč instancemi. Monitorování pravidel bikepoint_id například vytvoří jedinečné logické vyhodnocení pro každou jedinečnou stanici kol.

Pravidla

Pravidla definují podmínky, které chcete zjistit u objektů, a akce, které se mají provést při splnění těchto podmínek. Například pravidlo na mraznícím objektu může zjistit, kdy teplota překročí bezpečnou prahovou hodnotu, a automaticky odeslat e-mailové upozornění přiřazeným technikům.

Pravidla v aktivátoru můžou být bezstavová nebo stavová:

  • Bezstavová pravidla vyhodnocují každou událost izolovaně (například hodnota < 50).
  • Stavová pravidla udržují paměť napříč událostmi na objekt (například hodnota DECREASES, BECOMES, EXIT RANGE).

Aktivátor podporuje také vytváření pravidel na základě Fabric Data Warehouse výsledků dotazu SQL (Preview). Můžete definovat pravidla, která vyhodnocují dotaz SQL podle konfigurovatelného plánu, kontrolují podmínky pro sadu výsledků a aktivují akce při splnění podmínek. Tato funkce umožňuje monitorování dat skladu bez nutnosti streamovaných zdrojů. Další informace najdete v tématu Vytvoření pravidla upozornění pro dotaz SQL.

Stavové vyhodnocení spoléhá na:

  • Detekce delta: Sleduje změny mezi předchozími a současnými hodnotami událostí.
  • Časové uspořádání: Vyhodnocuje časové podmínky, jako je absence událostí (detekce srdečního tepu).
  • Přechody stavu: Pravidla se aktivují pouze při vstupu do nového stavu, což brání opakovanému vyřazování v nezměněných podmínkách.

Pravidla se vyhodnocují nepřetržitě. V případě bezstavových pravidel pro streamovaná data systém reaguje v milisekundách. U pravidel s agregacemi latence závisí na časovém okně a toleranci zpoždění. Další informace najdete v tématu Latence v aktivátoru.

Akce

Když jsou splněny podmínky pravidla a spustí se akce, aktivuje se pravidlo. Mezi podporované cíle pro akce patří:

  • Fabric potrubí (pro přesun dat, obohacování).
  • poznámkové bloky Fabric (pro hodnocení modelů strojového učení, diagnostiku).
  • Úlohy pro Fabric Spark (pro dávkové a streamované úlohy).
  • Datové toky Fabric (pro přesun a transformaci dat).
  • Fabric Funkce uživatelských dat (Preview) (pro vlastní obchodní logiku s kódem).
  • Power Automate procesy (pro integraci obchodních procesů).
  • Oznámení Teams (pomocí zasílání zpráv založených na šablonách)
  • E-mailová oznámení

Když se aktivuje pravidlo, triggeror odešle informace o tom, co se stalo, a pokračuje v monitorování bez čekání na dokončení akce. Tento přístup umožňuje škálovatelné pracovní postupy, které mohou zpracovávat mnoho událostí současně.

Vlastnosti

Vlastnosti jsou konkrétní pole nebo atributy obchodního objektu, který chcete monitorovat. Můžou to být fyzické nebo koncepční charakteristiky, například:

  • Teplota balení
  • Stav zásilky
  • Zůstatek zákaznického účtu
  • Skóre zapojení uživatelské relace

Vlastnosti pocházejí z událostí, což jsou průběžné toky dat ze zdrojů, jako jsou senzory IoT, Power BI sestavy nebo jiné systémy.

Když definujete obchodní objekt v aktivátoru, propojíte jeden nebo více eventstreamů, zvolíte sloupec, který bude sloužit jako ID objektu, a vyberete další sloupce, které se mají považovat za vlastnosti tohoto objektu. U těchto vlastností můžete vytvořit pravidla pro sledování změn v průběhu času, zjištění, kdy vlastnost překročí prahovou hodnotu nebo spadá mimo rozsah, nebo aktivovat akce, jako jsou výstrahy, pracovní postupy nebo oznámení.

Vlastnosti jsou užitečné také v případech, kdy chcete znovu použít logiku napříč několika pravidly. Na objektu mrazáku můžete například definovat vlastnost, která vypočítá průměr teploty za jednohodinovou dobu. Po definování můžete na tuto vlastnost odkazovat ve více pravidlech, jako jsou ty, které detekují přehřívání, kolísání teploty nebo prahové hodnoty údržby – bez duplikování logiky. Díky centralizaci logiky ve vlastnostech usnadňujete správu, konzistentnější a jednodušší aktualizaci v průběhu času.

Období pro zpětné hodnocení

Období zpětného pohledu je délka historických dat, kterou Aktivátor analyzuje k vyhodnocení pravidla. Zajišťuje, že existuje dostatek minulých dat k přesnému zjištění vzorů nebo výpočetních agregací, jako jsou průměry, i když data přicházejí pozdě nebo nepravidelně.

Období zpětného vyhledávání určíte podle:

  • Jak definujete pravidlo, například to, jestli vyžaduje analýzu trendů, zjišťování anomálií nebo porovnávání hodnot v průběhu času.
  • Objem příchozích dat, například počet událostí za sekundu v datovém proudu událostí.

Vezměte v úvahu farmaceutické logistické operace přepravující balíčky léků v studeném řetězci. Cílem je dostat upozornění, když se balíček stane příliš teplým.

Řekněme, že definujete pravidlo pro:

  • Vyhodnocení průměrné teploty každého balíčku v tříhodinovém intervalu
  • Aktivace výstrahy v případě, že průměrná teplota překročí 8°C

K přesnému výpočtu tohoto pravidla Fabric Aktivátor musí analyzovat širší okno historických dat (například šestihodinový interval zpětného vyhledávání pro tříhodinový průměr). Tento proces zajišťuje, že je k dispozici dostatek dat k výpočtu tříhodinového průměru v libovolném časovém okamžiku, i když data přicházejí s určitým zpožděním nebo nepravidelností.

Období zpětného vyhledávání je nezbytné pro včasné a přesné zjišťování podmínek, zejména ve scénářích, kdy se vzory dat v průběhu času vyvíjejí.

Jedinečné ID aktivního objektu

Pomocí pravidel založených na atributech můžete sledovat, jak se v průběhu času mění konkrétní atributy objektu. V příkladu farmaceutické logistiky je každý balíček léku reprezentován jedinečným ID objektu a systém přijímá pravidelné čtení teploty pro každý balíček.

Chcete-li tato pravidla efektivně vyhodnotit, Aktivátor Fabric sleduje ID aktivních objektů – to znamená objekty, pro které události přicházejí v zpětně definovaném období. Toto chování zajišťuje, že systém při použití pravidel považuje pouze relevantní, aktuálně aktivní objekty.

Například placená stanice může sledovat vozidla (ID objektů) při jejich průchodu. Každé vozidlo generuje události (například kontroly vstupu a výstupu) a systém vyhodnocuje pouze ty objekty s nedávnou aktivitou.

Počet jedinečných ID objektů (počet balíčků), které sledujete v okně zpětného vyhledávání, také nastavuje limity.

Běžné případy použití

Tady je několik scénářů z reálného světa, ve kterých můžete použít Fabric Aktivátor:

  • Automaticky spouštět reklamní kampaně v případě poklesu prodeje stejného obchodu, což pomáhá zvýšit výkon v podvýkonných umístěních.
  • Informujte manažery obchodu s potravinami, aby přemístili jídlo z nefunkčních mrazáků před tím, než dojde ke zkažení.
  • Aktivujte přizpůsobené pracovní postupy, pokud cesta zákazníka mezi aplikacemi, webovými stránkami nebo jinými kontaktními body naznačuje negativní zkušenosti.
  • Proaktivně zahajte pracovní postupy šetření, když se stav zásilky neaktualizuje v rámci definovaného časového rámce, což pomáhá rychleji vyhledat ztracené balíčky.
  • Upozorňujte účtovací týmy, když zákazníci upadnou do prodlení, s využitím přizpůsobených prahových hodnot pro dobu nebo nevyrovnané zůstatky na zákazníka.
  • Sledujte zdraví potrubí a automaticky znovu spusťte selhané úlohy nebo upozorněte týmy, když se zjistí anomálie nebo selhání.

Související obsah

  • Last updated on