Mi az Fabric Activator?

Fabric Activator egy kód nélküli eseményészlelési motor, amely automatizált műveletekké alakítja át az adatfolyamokat. Automatikusan aktiválja a műveleteket, ha bizonyos mintákat vagy feltételeket észlel az adatforrásokban. Folyamatosan figyeli ezeket az adatforrásokat alacsony késéssel (a streamelési adatok állapot nélküli szabályainak alszekunduma), és műveleteket kezdeményez küszöbértékek elérésekor vagy meghatározott minták észlelésekor. Ilyen műveletek lehetnek például e-mailek vagy Teams-értesítések küldése, Power Automate folyamatok indítása vagy külső rendszerekkel való integráció.

Alapvető architektúra

Az Activator az eseményészlelési és szabálymotor, amely a Fabric Real-Time intelligencia-verem központi eleme. Architekturálisan intelligens megfigyelőként működik : nagy sebességű adatfolyamokat használ, közel valós időben értékeli a szabályfeltételeket, és automatizált alárendelt műveleteket kezdeményez az eseményállapotok változásai alapján.

Illeszkedik egy reaktív, eseményvezérelt architektúrába, ahol az adatok folyamatosan áramlnak, és az Activator az eseményadatok állapotalapú kiértékelése alapján hoz döntéseket közel valós időben.

Diagram, amely a Fabric Activator architektúráját mutatja be.

  • Eseményforrások

    Az Activator közvetlenül az eventstreamekhez csatlakozik, amelyek különböző gyártóktól (Azure Event Hubs, IoT-eszközöktől, egyéni végpontoktól és más forrásoktól) származó adatokat fogadnak be. Ezek a streamek szolgálnak az események forrásaként, és az Activator feliratkozhat egy vagy több eseménystreamre az adatváltozások megfigyeléséhez. Más eseményforrás lehetnek Fabric- vagy Azure-események, vagy egy Power BI jelentést vagy egy valós idejű irányítópultot figyelő aktiváló.

  • Események és objektumok

    Az események az eventstreamen keresztül fogadott egyedi feljegyzések (például telemetriai jelek vagy fájlátvitel). Ezek az események egy megosztott azonosító alapján objektumokba vannak csoportosítva (például az ugyanazon eszközről származó összes esemény csoportosítva device_idvan, vagy az összes kerékpárállomás-esemény csoportosítva bikepoint_idvan). A szabályok kiértékelése ezután objektumonként történik, ami lehetővé teszi a részletes észlelést (például érzékelőnként vagy objektumonként).

  • Szabályok és feltételek

    Minden aktiváló tartalmaz egy vagy több szabályt, amelyeket a rendszer folyamatosan kiértékel. Ezek a szabályok lehetnek egyszerű összehasonlítások (value < threshold) vagy olyan feltételek, amelyek nyomon követik az idő változásait, például BECOMES, DECREASES, INCREASES, EXIT RANGEvagy az adatok hiányát (szívverés). Az Activator biztosítja az állapotkövetést objektumonként, ami lehetővé teszi az összetett minták időbeli észlelését.

  • Műveletek

    Ha egy szabályfeltétel teljesül, az Activator a következőket aktiválhatja:

    • folyamatok, jegyzetfüzetek, adatfolyamok, felhasználói adatfüggvények (UDF-ek), spark-feladatdefiníciók, feladatok másolása (előzetes verzió) vagy üzleti esemény közzététele (előzetes verzió) a Fabric.

    • Külső műveletek Power Automate keresztül.

    • Teams-üzenet küldése egyéni, csoport vagy csatorna számára.

    • E-mail küldése.

  • Riasztáskezelés és szabálytesztelés

    Az Activator előnézetet és hatásbecslést biztosít a szabályok aktiválása előtt, megmutatva, hogy egy szabály milyen gyakran lett volna alkalmazva a történeti adatokon. Ezek a funkciók segítenek megelőzni a riasztási spamet és a túlműködést. Az állapotváltások belsőleg úgy vannak kezelve, hogy elnyomják a zajt (például egy értéknek át kell haladnia egy küszöbértéket, és nem csak alatta kell maradnia).

  • Monitorozás és költségkezelés

    Csak akkor merül fel költség, ha az aktiválók aktívan futnak. Az aktivátor példányok hatóköre a Fabric kapacitásokra terjed ki, és a munkaterületen keresztül monitorozhatók. A futásidejű naplók és a telemetriai adatok eseménystreameken és folyamatkimeneteken keresztül érhetők el.

Üzembehelyezési modell

Helyezzen üzembe aktiválási példányokat minden munkaterületen, és kösse őket meghatározott adatforrásokhoz. Több aktivátor is figyelheti ugyanazt a streamet, így használhat párhuzamos szabályértékeléseket különböző üzleti függvényekhez. Mivel az aktivátor kapacitáshoz kötött, a használatalapú fizetéses díjszabás csak akkor érvényes, ha a szabályok aktívan futnak. Ez a díjszabási modell költséghatékonyságot biztosít az időszakos észlelési forgatókönyvekhez. Az ismert korlátozásokért tekintse meg az Activator korlátait.

Integrációs pontok Real-Time intelligencián belül

Összetevő Interakció az Activator használatával
Eventstream Valós idejű adatokat küld az Activatornak, hogy nyomon tudja követni a mintákat és a feltételeket. A riasztások létrehozása és a szabálykezelés közvetlenül az Eventstreambe is beágyazva van, így a felhasználók a környezetben hozhatnak létre és kezelhetnek szabályokat.
Aktivátor Létrehozhat új eseményeket, például bővített adatokat vagy kategorizált adatokat, amelyek egy másik aktiválót aktiválnak.
Pipeline Az Activator szabályindítóinak célja, amely automatizálja az alsóbb rétegbeli feldolgozást.
Power BI A jelentésvizualizációk Activator-szabályainak eseményforrásaként szolgál, beleértve a táblázat vizuális sorainak észlelését is. Emellett az aktivált folyamatok vagy jegyzetfüzetek eredményét is felhasználja valós idejű vizualizációkhoz.
Power Automate Előre összeállított vagy egyéni munkafolyamatokkal automatizálja a feladatokat események bekövetkezésekor.
Fabric események Olyan eseményeket biztosít, amelyek a Fabricben történnek, például egy szemantikai modell frissítése vagy egy adatátviteli folyamat meghiúsulása.
Notebooks Az Activator elindíthatja a jegyzetfüzet végrehajtását.
Spark-munka definíciója Az Activator elindíthatja a Spark-feladat végrehajtását.
Felhasználói adatfunkció Az Activator aktiválhatja a Felhasználói adatok függvény (UDF) végrehajtását.
Adatfolyam Az Activator aktiválhatja az adatfolyam-végrehajtást egy szabályfeltétel teljesülése esetén.
Másolási feladat (előzetes verzió) Az Activator aktiválhatja a másolási feladat végrehajtását egy szabályfeltétel teljesülése esetén.
Üzleti esemény közzététele (előzetes verzió) Az Activator aktiválhatja egy üzleti esemény közzétételét egy szabályfeltétel teljesülése esetén.

Activator, mint orkesztrátor

Ha hatékonyan szeretné használni az Activatort nagy méretű rendszerekben, koordinálja az egyéb Fabric összetevőkkel való működését. Optimalizálhatja a beállításokat a feldolgozni kívánt adatok, a nyomon követett objektumok és a szabályok összetettség alapján. Ez a szakasz bemutatja, hogyan vezényelheti az Activatort más szolgáltatásokkal, és hogyan optimalizálhatja az észlelési logikát és a futtatókörnyezet viselkedését az alacsony késleltetésű (gyors), költséghatékony, nagy léptékű automatizálás támogatása érdekében.

Az Activator központi szerepet játszik az eseményvezérelt folyamatokban azáltal, hogy kiértékeli az adatokat az érkezési ponton, és aktiválja a műveleteket az alsóbb rétegben. A vezénylés tipikus mintái a következők:

Pattern Folyamat leírása
Betöltés → Észlelés → Átalakítás Az események az Eventstreamből az Activatorba áramlanak, amely elindít egy folyamatot az adatok bővítéséhez vagy áthelyezéséhez.
Betöltési → észlelési → értesítés Az Activator aktiválja a Power Automate-ot, hogy riasztásokat küldjön, vagy állapotot jelezzen a Teamsbe, Outlookba vagy ServiceNow-ba.
Adatbetöltés → Detektálás → Modell pontozás Az Activator elindít egy jegyzetfüzetet egy ML-modell pontozásához vagy a valós idejű anomáliákon alapuló speciális elemzések végrehajtásához.
Visszajelzési ciklus az Activator használatával (tervezett) Az Activator által létrehozott észlelések (például bizalmassági címkék) bekerülnek az Activator-szabályokba, ami lehetővé teszi a szemantikailag gazdagított automatizálást.

Alapfogalmak

Fabric Activator folyamatosan figyeli az adatokat, és gyorsan észleli, hogy mikor teljesülnek a megadott feltételek, még akkor is, ha az adatok idővel változnak. Az Activator alapvető feladata az eseményfolyamon keresztül kibocsátott valós idejű események feldolgozása, a szabályfeltételek logikai objektumonkénti kiértékelése és az állapotváltásokra reagáló műveletek kezdeményezése.

Az alábbi fogalmak segítségével automatikus műveleteket és válaszokat hozhat létre és aktiválhat az Fabric Activatorban.

Eseményforrások és események

Fabric Az Activator az összes adatforrást események adatfolyamaként kezeli. Az esemény egy objektum állapotának megfigyelését jelenti, és általában tartalmazza az objektum azonosítóját, az időbélyeget és a figyelt mezők értékeit.

Az Activatorba betöltött események forrása:

  • Eventstream, amely több felsőbb rétegbeli forrást támogat (például Azure Event Hubs, IoT Hub, Blob Storage eseményindítókat). Az eventstream egy adott elemtípus a Microsoft Fabric, amely lehetővé teszi valós idejű események betöltését, átalakítását és irányítását kód írása nélkül. Fabric Az Activator figyeli az eseményfolyamot, és automatikusan végrehajtja a műveletet meghatározott minták vagy küszöbértékek észlelésekor. Az Activator két vagy több eseménystreamre is feliratkozhat az adatváltozások megfigyeléséhez. Az eseménystreamek gyakorisága változó. Az IoT-érzékelők például másodpercenként többször bocsátanak ki eseményeket, a logisztikai rendszerek pedig szórványosan generálnak eseményeket, például amikor a csomagokat a szállítási helyeken ellenőrzik.
  • Fabric események. Például a Fabric munkaterületelem-események olyan különálló Fabric események, amelyek akkor következnek be, amikor módosításokat hajtanak végre a Fabric munkaterületen. Ezek a módosítások közé tartozik egy Fabric elem létrehozása, frissítése vagy törlése.
  • Azure események. Például Azure Blob Storage események akkor aktiválódnak, amikor egy ügyfél létrehoz, lecserél vagy töröl egy blobot.
  • Üzleti események. A riasztásokat közvetlenül az üzleti eseményeken állíthatja be, hogy automatizálja a műveleteket adott üzleti feltételek bekövetkezésekor.
  • Fabric Ontology üzleti entitások (előzetes verzió). Az ontológiai üzleti entitásokon szabályok határozhatók meg a riasztások és az automatizált műveletek kezdeményezéséhez, lehetővé téve a modellezett adatokon alapuló üzemeltetési döntéshozatalt.
  • Power BI jelentés. Ebben az esetben az események rendszeres megfigyelések egy Power BI szemantikai modell (korábbi nevén adathalmaz) frissítési ütemezése alapján. Ezek a megfigyelések naponta vagy hetente fordulhatnak elő, és lassú eseményfolyamot alkotnak. Az Activator a Power BI szolgáltatással integrálva figyelmezteti a felhasználókat, ha egy új sor jelenik meg egy táblavizualizációban egy közzétett jelentésben, lehetővé téve a szabályok számára, hogy vizualizáció szintű változásokat figyelje, valamint értesítéseket vagy követő műveleteket aktiváljanak.
  • Fabric Real-Time Irányítópult.

Minden esemény a következőket tartalmazza:

  • Időbélyeg
  • Hasznos adat (strukturált vagy részben strukturált adatok)
  • Objektumazonosításhoz használt egy vagy több attribútum (például device_id, bikepoint_id)

Objektumokat

Az Fabric Activatorban a megfigyelt entitásokat üzleti objektumoknak nevezzük, amelyek lehetnek fizikai vagy fogalmiak. Ilyenek például a fizikai objektumok, például a fagyasztók, a járművek, a csomagok és a felhasználók, valamint az olyan fogalmi objektumok, mint a hirdetési kampányok, az ügyfélfiókok, a felhasználói munkamenetek.

Ha üzleti objektumot szeretne modelleztetni az Activatorban, egy vagy több eseményfolyamot csatlakoztathat, kijelölhet egy oszlopot, amely objektumazonosítóként szolgál, és megadhatja az objektum tulajdonságaiként kezelni kívánt mezőket.

Az objektumpéldány kifejezés egy üzleti objektum adott példájára utal, például egy adott fagyasztóra, járműre vagy felhasználói munkamenetre. Ezzel szemben az objektum általában az általános definícióra vagy osztályra hivatkozik (például fagyasztó típusként). A sokaság kifejezés a figyelendő objektumpéldányok teljes készletére szolgál.

Az objektumlétrehozás implicit: Az aktivátor egy kijelölt objektumkulcs használatával csoportosítja az eseményeket. A szabályok hatóköre objektumokra terjed ki, ami azt jelenti, hogy minden kiértékelési logika objektumérzékeny és független a példányok között. A szabályfigyelés bikepoint_id például külön logikai értékeléseket hoz létre minden egyes egyedi kerékpárállomáshoz.

Szabályok

A szabályok meghatározzák az objektumokon észlelni kívánt feltételeket és a feltételek teljesülése esetén végrehajtandó műveleteket. Egy fagyasztóobjektumra vonatkozó szabály például észlelheti, ha a hőmérséklet egy biztonságos küszöbérték fölé emelkedik, és automatikusan e-mail-riasztást küld a hozzárendelt technikusnak.

Az Activator szabályai állapot nélküliek vagy állapotalapúak lehetnek:

  • Az állapot nélküli szabályok elkülönítve értékelik ki az egyes eseményeket (például 50-et < ).
  • Az állapotalapú szabályok objektumonkénti eseményeken (például ÉRTÉKCSÖKKENÉS, LESZ, KILÉPÉSI TARTOMÁNY) tartják fenn a memóriát.

Az Activator Fabric Data Warehouse SQL-lekérdezés eredményei (előzetes verzió) alapján is támogatja a szabályok létrehozását. Definiálhat olyan szabályokat, amelyek konfigurálható ütemezés szerint értékelik ki az SQL-lekérdezéseket, ellenőrzik az eredményhalmaz feltételeit, és a feltételek teljesülése esetén aktiválják a műveleteket. Ez a funkció lehetővé teszi a raktáradatok figyelését streamforrások megkövetelése nélkül. További információ: Riasztási szabály létrehozása SQL-lekérdezésen.

Az állapotalapú értékelés a következőre támaszkodik:

  • Változásészlelés: Nyomon követi a korábbi és az aktuális eseményértékek közötti változásokat.
  • Időbeli sorrend: Kiértékeli az időalapú feltételeket, például az események hiányát (szívverésészlelés).
  • Állapotváltások: A szabályok csak az új állapotba való belépéskor aktiválódnak, megakadályozva az ismétlődő tüzeléseket változatlan körülmények között.

A szabályok kiértékelése folyamatosan történik. A streamelés állapot nélküli szabályai esetén a rendszer milliszekundumok alatt válaszol. Az összesítéssel rendelkező szabályok esetében a késés a visszatekintési időszaktól és a késői érkezési tűréstől függ. További információ: Késés az Activatorban.

Műveletek

Amikor egy szabály feltételei teljesülnek, és egy műveletet kezdeményeznek, a szabály aktiválódik. A műveletek támogatott céljai a következők:

  • Fabric csővezetékek (adatáthelyezéshez, gazdagításhoz).
  • Fabric jegyzetfüzetek (gépi tanulási pontozáshoz, diagnosztikához).
  • Fabric Spark-feladatok (kötegelt és streamelési munkákhoz).
  • Fabric adatfolyamok (az adatok mozgatására és átalakítására).
  • Fabric felhasználói adatfüggvények (egyéni üzleti logikához, kód használatával).
  • Fabric másolási feladatok (előzetes verzió) (az adatok források és célhelyek közötti másolásához).
  • Üzleti esemény közzététele (előzetes verzió) (üzleti eseményeket használó alsóbb rétegbeli folyamatok aktiválásához).
  • Power Automate flowk (üzleti folyamatok integrálása céljából).
  • Teams-értesítések (sablonalapú üzenetküldés használatával).
  • E-mailes értesítések.

Amikor egy szabály aktiválódik, az Activator információkat küld a történtekről, és anélkül folytatja a figyelést, hogy megvárja a művelet befejezését. Ez a megközelítés skálázható munkafolyamatokat tesz lehetővé, amelyek egyszerre több eseményt is feldolgozhatnak.

Tulajdonságok

A tulajdonságok egy figyelni kívánt üzleti objektum adott mezői vagy attribútumai. Ezek lehetnek fizikai vagy fogalmi jellemzők, például:

  • Csomag hőmérséklete
  • Szállítmány állapota
  • Ügyfélfiók egyenlege
  • Felhasználói munkamenet elkötelezettségi pontszáma

A tulajdonságok eseménystreamekből származnak, amelyek olyan forrásokból származó folyamatos adatfolyamok, mint az IoT-érzékelők, Power BI jelentések vagy más rendszerek.

Amikor üzleti objektumot definiál az Activatorban, összekapcsol egy vagy több eseménystreamet, kiválaszt egy oszlopot, amely objektumazonosítóként szolgál, és kijelöl más oszlopokat, amelyeket az objektum tulajdonságaiként kezel. Ezekre a tulajdonságokra szabályokat hozhat létre a változások időbeli nyomon követéséhez, észlelheti, ha egy tulajdonság túllép egy küszöbértéket, vagy túllép egy tartományt, vagy riasztásokat, munkafolyamatokat vagy értesítéseket aktivál.

A tulajdonságok akkor is hasznosak, ha több szabályban szeretné újra felhasználni a logikát. Egy fagyasztóobjektumon például meghatározhat egy olyan tulajdonságot, amely egy óra alatt kiszámítja a hőmérséklet átlagát. A definiálást követően több szabályban is hivatkozhat erre a tulajdonságra, például a túlmelegedést, a hőmérséklet-ingadozásokat vagy a karbantartási küszöbértékeket észlelő szabályokban – a logika duplikálása nélkül. A tulajdonságok logikáinak központosításával egyszerűbbé teheti a szabályok kezelését, konzisztensebbé és könnyebben frissíthetővé teszi azokat az idők során.

Visszatekintési időszak

A visszatekintési időszak azoknak az előzményadatoknak az időtartama, amelyeket az Activator elemez egy szabály kiértékeléséhez. Biztosítja, hogy elegendő múltbeli adat legyen a minták vagy az átlagokhoz hasonló összesítések pontos észleléséhez, még akkor is, ha az adatok későn vagy szabálytalanul érkeznek.

A visszatekintési időszakot a következővel határozhatja meg:

  • A szabály definiálásának módját, például azt, hogy trendek elemzésére, anomáliák észlelésére vagy értékek időbeli összehasonlítására van-e szükség.
  • A bejövő adatok mennyisége, például az eseménystreamben másodpercenkénti események száma.

Fontolja meg egy gyógyszeripari logisztikai műveletet, amely gyógyszercsomagokat szállít egy hideg láncban. A cél egy riasztás fogadása, ha egy csomag túl meleg lesz.

Tegyük fel, hogy a szabályt a következőre definiálja:

  • Az egyes csomagok átlagos hőmérsékletének kiértékelése háromórás időszakon keresztül
  • Riasztás aktiválása, ha az átlaghőmérséklet meghaladja a 8°C-ot

A szabály pontos kiszámításához Fabric Activatornak az előzményadatok szélesebb ablakát kell elemeznie (például egy hat órás visszatekintési időszakot egy háromórás átlaghoz). Ez a folyamat biztosítja, hogy elegendő adat legyen a háromórás átlag kiszámításához bármikor, még akkor is, ha az adatok késéssel vagy szabálytalansággal érkeznek.

A visszatekintési időszak elengedhetetlen a feltételek időszerű és pontos észlelésének lehetővé tételéhez, különösen olyan helyzetekben, ahol az adatminták idővel fejlődnek.

Különálló, aktív objektumazonosítók

Az attribútumokra épülő szabályok segítségével monitorozhatja, hogy egy objektum adott attribútumai hogyan változnak az idő függvényében. A gyógyszerlogisztikai példában minden gyógyszercsomagot egyedi objektumazonosító jelöl, és a rendszer minden csomaghoz rendszeres hőmérséklet-mérést kap.

A szabályok hatékony kiértékeléséhez Fabric Activator az aktív objektumazonosítókat követi nyomon, vagyis azokat az objektumokat, amelyekhez az események a megadott visszatekintési időszakon belül érkeznek. Ez a viselkedés biztosítja, hogy a rendszer csak releváns, jelenleg aktív objektumokat tekintsen a szabályok alkalmazásakor.

Egy útdíjszedő állomás például nyomon követheti a járműveket (objektumazonosítókat), miközben áthaladnak. Minden jármű eseményeket hoz létre (például be- és kilépési vizsgálatokat), és a rendszer csak azokat az objektumokat értékeli ki, amelyek nemrég voltak aktívak.

A visszatekintő ablakban nyomon követett különböző objektumazonosítók (csomagok száma) száma is korlátokat állít be.

Gyakori használati esetek

Íme néhány valós forgatókönyv, ahol Fabric Activatort használhatja:

  • Automatikusan elindítja a hirdetéskampányokat, ha az azonos áruházbeli értékesítések csökkennek, ezzel növelve a teljesítményt az alulteljesítő helyeken.
  • Értesítse az élelmiszerboltok vezetőit, hogy helyezzenek át élelmiszert a hibás fagyasztókból, mielőtt megromlanak az ételek.
  • Kapcsolatteremtési munkafolyamatokat aktiváld személyre szabottan, ha az ügyfél útja alkalmazásokon, webhelyeken vagy más érintőpontokon negatív élményt jelez.
  • Proaktív módon kezdeményezhet vizsgálati munkafolyamatokat, ha egy szállítmány állapota nem frissül egy meghatározott időkereten belül, így gyorsabban megtalálhatja az elveszett csomagokat.
  • Értesítse a fiókcsapatokat, ha az ügyfelek elmaradásokba kerülnek, egyéni küszöbértékek alapján, idő vagy kintlévőség szerint, ügyfélenként.
  • Figyelheti a folyamat állapotát, és automatikusan újrafuttathatja a meghiúsult feladatokat vagy riasztási csoportokat, ha rendellenességeket vagy hibákat észlel.

Kapcsolódó tartalom

  • Last updated on