Megosztás a következőn keresztül:

Adatfolyamok átirányítása a Fabric-eseménystreamek tartalma alapján (előzetes verzió)

  • Cikk

Ez a cikk bemutatja, hogyan irányíthatja az eseményeket a Microsoft Fabric-eseménystreamek tartalma alapján.

A Fabric-eseménystreamek fővásznon a kód nélküli szerkesztő használatával összetett streamfeldolgozási logikát hozhat létre kód írása nélkül. Ez a funkció lehetővé teszi az adatfolyamok egyszerűbb testreszabását, átalakítását és kezelését. A streamfeldolgozási műveletek beállítása után zökkenőmentesen küldheti el az adatfolyamokat különböző helyekre az adott séma és streamadatok alapján.

Fontos

A Fabric-eseménystreamek továbbfejlesztett képességei jelenleg előzetes verzióban érhetők el.

Támogatott műveletek

A valós idejű adatfeldolgozáshoz támogatott műveletek listája:

  • Összesítés: Támogatja a SUM, AVG, MIN és MAX függvényeket, amelyek egy értékoszlopon végeznek számításokat, és egyetlen eredményt ad vissza.

  • Kibontás: Bontsa ki a tömbértékeket, és hozzon létre egy új sort a tömbön belüli összes értékhez.

  • Szűrés: Adott sorok kijelölése vagy szűrése az adatfolyamból feltétel alapján.

  • Csoportosítás: Az összes eseményadat összesítése egy adott időkereten belül, egy vagy több oszlop csoportosításának lehetőségével.

  • Mezők kezelése: Az adatfolyamok mezőinek vagy oszlopainak adattípusának hozzáadása, eltávolítása vagy módosítása.

  • Unió: két vagy több adatfolyamot Csatlakozás azonos nevű és adattípusú megosztott mezőkkel egy adatfolyamba. A nem egyező mezők el lesznek dobva.

  • Illesztés: Két stream adatainak egyesítése egyező feltétel alapján.

Támogatott célhelyek

A támogatott célhelyek a következők:

  • Lakehouse: Ez a cél lehetővé teszi, hogy átalakítsa a valós idejű eseményeket a betöltés előtt a lakehouse. A valós idejű események Delta Lake formátumúvá alakulnak, majd a kijelölt lakehouse-táblákban tárolják őket. Ez a cél segít az adattárházi forgatókönyvekben.

  • KQL-adatbázis: Ez a cél lehetővé teszi a valós idejű eseményadatok KQL-adatbázisba való betöltését, ahol a hatékony Kusto lekérdezésnyelv (KQL) használatával lekérdezheti és elemezheti az adatokat. A KQL Database adataival mélyebb betekintést nyerhet az eseményadatokba, és gazdag jelentéseket és irányítópultokat hozhat létre.

  • Reflex: Ezzel a céllal közvetlenül csatlakoztathatja valós idejű eseményadatait egy Reflexhez. A Reflex egy intelligens ügynöktípus, amely tartalmazza az adatokhoz való csatlakozáshoz, a feltételek monitorozásához és a cselekvéshez szükséges összes információt. Amikor az adatok elérik bizonyos küszöbértékeket, vagy megegyeznek más mintákkal, a Reflex automatikusan végrehajtja a megfelelő műveletet, például a felhasználók riasztását vagy a Power Automate-munkafolyamatok elindítását.

  • Egyéni végpont (korábbi egyéni alkalmazás): Ezzel a céllal egyszerűen átirányíthatja valós idejű eseményeit egy egyéni alkalmazásba. Ez a cél lehetővé teszi saját alkalmazások csatlakoztatását az eseménystreamhez, és valós időben felhasználhatja az eseményadatokat. Ez akkor hasznos, ha valós idejű adatokat szeretne kibocsátani a Microsoft Fabricen kívüli külső rendszerbe.

  • Stream: Ez a cél azt az alapértelmezett nyers eseményfolyamot jelöli, amelyet egy műveletsorozat, más néven származtatott stream alakít át. A létrehozás után megtekintheti a streamet a valós idejű központból.

Az alábbi példa bemutatja, hogy három különböző Fabric-eseménystream-célhely hogyan képes különálló függvényeket kiszolgálni egyetlen adatfolyam-forráshoz. Egy KQL-adatbázis van kijelölve nyers adatok tárolására, egy második KQL-adatbázis a szűrt adatfolyamok megőrzésére, a Lakehouse pedig az összesített értékek tárolására szolgál.

Képernyőkép a tartalomon alapuló útválasztási eseményekről.

Ha tartalom alapján szeretné átalakítani és irányítani az adatfolyamot, kövesse az Eseményfolyam szerkesztése és közzététele című szakasz lépéseit, és kezdje el az adatfolyam adatfolyam-feldolgozási logikáinak tervezését.

Kapcsolódó tartalom