Adatfolyamok streamelése (előzetes verzió)

A szervezetek nem napokkal vagy hetekkel később, hanem az adatokkal szeretnének dolgozni. A Power BI víziója egyszerű: a kötegelt feldolgozás, a valós idejű feldolgozás és az adatfolyam-feldolgozás közötti különbségeknek el kell tűnniük. A felhasználóknak az összes adattal dolgozniuk kell, amint az elérhető. Az elemzőknek általában technikai segítségre van szükségük a streamelési adatforrások, az adatelőkészítés, az összetett időalapú műveletek és a valós idejű adatvizualizációk kezeléséhez. Az informatikai részlegek gyakran egyénileg létrehozott rendszerekre és különböző gyártók technológiáinak kombinációjára támaszkodnak, hogy időben elemezhessenek az adatokon. E bonyolultság nélkül nem tudnak közel valós időben információt szolgáltatni a döntéshozóknak.

A streaming adatfolyamok lehetővé teszik a készítők számára, hogy közvetlenül a Power BI szolgáltatásban kapcsolódjanak a közel valós időben streamelt adatokhoz, betöltsék, egyesítsék és modellezzék azokat, valamint ezek alapján jelentéseket készítsenek. A szolgáltatás lehetővé teszi az áthúzásos, kód nélküli szolgáltatásokat. A streamingadatokat szükség esetén batchadatokkal is kombinálhatja egy olyan felhasználói felületen (UI) keresztül, amely az egyszerű adatösszevonáshoz diagramnézetet is tartalmaz. A végső előállított elem egy adatfolyam, amely valós időben felhasználható, és rendkívül interaktív, közel valós idejű jelentéskészítést eredményez. A Power BI összes adatvizualizációs funkciója ugyanúgy működik a streamingadatokkal, mint a kötegelt adatokkal.

Fontos

A streaming adatfolyamok kivezetésre kerültek, és már nem érhetők el. Az Azure Stream Analytics egyesítette a streamelési adatfolyamok funkcióit. A streamelési adatfolyamok kivonásával kapcsolatos további információkért lásd a kivonásról szóló közleményt. A felhasználók adat-előkészítési műveleteket hajthatnak végre, például illesztéseket és szűrőket. Emellett időablak-alapú aggregációkat is végezhetnek (például rögzített, ugró és munkamenetablakok esetén) a GROUP BY műveletekhez. Adatfolyamok streamelése a Power BI-ban lehetővé teszi a szervezetek számára a következő lehetőségeket:

• Hozzon magabiztos döntéseket közel valós időben. A szervezetek rugalmasabbak lehetnek, és a legfrissebb elemzések alapján értelmes műveleteket hajthatnak végre.
• Streamelési adatok demokratizálása. A szervezetek akadálymentesebbé és könnyebben értelmezhetővé tehetik az adatokat kód nélküli megoldásokkal, és ez az akadálymentesség csökkenti az informatikai erőforrásokat.
• Gyorsítsa fel az értékes felismerésekhez szükséges időt egy integrált adattárolást és üzleti intelligenciát kínáló, teljes körű streamingelemzési megoldással.

A streamelési adatfolyamok támogatják a DirectQueryt és az automatikus oldalfrissítést/módosításészlelést. Ez a támogatás lehetővé teszi a felhasználók számára, hogy a Power BI-ban elérhető vizualizációk használatával közel valós időben, másodpercenként frissülő jelentéseket készítsenek.

Követelmények

Az első streamelési adatfolyam létrehozása előtt győződjön meg arról, hogy megfelel az alábbi követelményeknek:

• Streamelési adatfolyam létrehozásához és futtatásához olyan munkaterületre van szükség, amely Premium kapacitás vagy Premium felhasználónkénti (PPU) licenc részét képezi.

  Fontos

  Ha PPU-licencet használ, és azt szeretné, hogy más felhasználók valós időben frissített streamelési adatfolyamokkal létrehozott jelentéseket használjanak, pPU-licencre is szükségük lesz. Ezután a beállított frissítési gyakorisággal használhatják fel a jelentéseket, ha a frissítés gyorsabb, mint 30 percenként.

• Adatfolyamok engedélyezése a bérlő számára. További információ: Adatfolyamok engedélyezése a Power BI Premiumban.

• Ahhoz, hogy a streamelési adatfolyamok működjenek a prémium szintű kapacitásban, be kell kapcsolni a továbbfejlesztett számítási motort . A motor alapértelmezés szerint be van kapcsolva, de a Power BI-kapacitásgazdák kikapcsolhatják. Ha igen, forduljon a rendszergazdához, és kapcsolja be.

  A továbbfejlesztett számítási motor csak Prémium P vagy Embedded A3 és nagyobb kapacitásokban érhető el. Streamelési adatfolyamok használatához PPU-ra, bármilyen méretű Prémium P-kapacitásra, beágyazott A3-ra vagy nagyobb kapacitásra van szükség. A Prémium termékváltozatokról és azok specifikációiról további információt a Power BI embedded analytics kapacitása és termékváltozatai című témakörben talál.

• Valós időben frissített jelentések létrehozásához győződjön meg arról, hogy a rendszergazda (a kapacitás vagy a Power BI for PPU) engedélyezte az automatikus oldalfrissítést. Győződjön meg arról is, hogy a rendszergazda engedélyezte az igényeinek megfelelő minimális frissítési időközt. További információ: Automatikus oldalfrissítés a Power BI-ban.

Streaming adatfolyam létrehozása

A streamingadatfolyam az adatfolyamhoz hasonlóan a Power BI szolgáltatás munkaterületein létrehozott és kezelt entitások (táblák) gyűjteménye. A táblák olyan mezők, amelyek az adatok tárolására szolgálnak, hasonlóan az adatbázison belüli táblákhoz.

Közvetlenül abból a munkaterületről adhat hozzá és szerkeszthet táblákat a streamelési adatfolyamban, amelyben az adatfolyam létre lett hozva. A normál adatfolyamok fő különbsége, hogy nem kell aggódnia a frissítések vagy a gyakoriság miatt. A streamelési adatok természetéből adódóan folyamatos adatfolyam érkezik. A frissítés állandó vagy végtelen, hacsak nem állítja le.

Megjegyzés

Munkaterületenként csak egy adatfolyamtípussal rendelkezhet. Ha már rendelkezik rendszeres adatfolyamkal a Prémium munkaterületen, nem fog tudni streamelési adatfolyamot létrehozni (és fordítva).

Streaming adatfolyam létrehozása:

1. Nyissa meg a Power BI szolgáltatás egy böngészőben, majd válasszon egy Prémium szintű munkaterületet. (A streamelési adatfolyamok, például a normál adatfolyamok nem érhetők el a következő helyen: Saját munkaterület.)

2. Válassza az Új legördülő menüt, majd a Streamelési adatfolyam lehetőséget.

   

3. A megnyíló oldalpanelen el kell neveznie a streamelési adatfolyamot. Adjon meg egy nevet a Név mezőbe (1), majd válassza a Létrehozás (2) lehetőséget.

   

   Megjelenik a streamelt adatfolyamok üres diagramnézete.

Az alábbi képernyőképen egy befejezett adatfolyam látható. Kiemeli a streamelési adatfolyam felhasználói felületén való létrehozáshoz rendelkezésre álló összes szakaszt.

1. Menüszalag: A menüszalagon a szakaszok a "klasszikus" elemzési folyamat sorrendjét követik: bemenetek (más néven adatforrások), átalakítások (streamelési ETL-műveletek), kimenetek és egy gomb a haladás mentéséhez.

2. Diagram nézet: Ez a nézet az adatfolyam grafikus ábrázolása a bemenetektől a műveleteken át a kimenetekig.

3. Oldalpanel: Attól függően, hogy melyik összetevőt választja ki a diagramnézetben, az egyes bemenetek, átalakítások vagy kimenetek módosítására vonatkozó beállításokat kell megadnia.

4. Tabulátorok az adatelőnézethez, a szerzői hibákhoz és a futtatókörnyezeti hibákhoz: Minden megjelenített kártya esetében az adatelőnézet az adott lépés eredményeit jeleníti meg (élőben a bemenetekhez és az átalakítások és kimenetek igény szerinti megjelenítéséhez).

   Ez a szakasz az adatfolyamokban esetlegesen előforduló szerzői hibákat vagy figyelmeztetéseket is összefoglalja. Az egyes hibák vagy figyelmeztetések kijelölése kiválasztja az adott transzformációt. Emellett az adatfolyam futtatása után futtatókörnyezeti hibákhoz is hozzáférhet, például elvetett üzenetekhez.

   A streamelési adatfolyamok ezen szakaszát mindig minimalizálhatja a jobb felső sarokban található nyílra kattintva.

A streamelési adatfolyam három fő összetevőre épül: streambemenetekre, átalakításokra és kimenetekre. Annyi összetevővel rendelkezhet, amennyit csak szeretne, beleértve a több bemenetet, a több átalakítással rendelkező párhuzamos ágakat és több kimenetet.

Streamelési bemenet hozzáadása

Streambemenet hozzáadásához válassza a menüszalag ikonját, és adja meg az oldalpanelen a beállításhoz szükséges információkat. 2021 júliusától a streamelési adatfolyamok előzetes verziója bemenetként támogatja az Azure Event Hubsot és az Azure IoT Hubot .

Az Azure Event Hubs és az Azure IoT Hub szolgáltatásai egy közös architektúrára épülnek, amely megkönnyíti az események gyors és méretezhető betöltését és felhasználását. Az IoT Hub elsősorban központi üzenetközpontként van kialakítva az IoT-alkalmazások és a csatlakoztatott eszközök közötti kommunikáció mindkét irányban történő kommunikációhoz.

Azure Event Hubs

Az Azure Event Hubs egy big data streamelési platform és eseménybetöltési szolgáltatás. Másodpercenként több millió eseményt képes fogadni és feldolgozni. Az eseményközpontba küldött adatok bármely valós idejű elemzési szolgáltatóval átalakíthatók és tárolhatók, illetve kötegelési vagy tárolási adaptereket is használhat.

Ha eseményközpontot szeretne konfigurálni adatfolyamok bemeneteként, válassza az Event Hub ikont . Megjelenik egy kártya a diagram nézetben, beleértve a konfiguráció oldalpaneljét is.

Lehetősége van az Event Hubs kapcsolati sztring beillesztésére. A streamelési adatfolyamok kitöltik az összes szükséges információt, beleértve az opcionális fogyasztói csoportot is (amely alapértelmezés szerint $Default). Ha manuálisan szeretné megadni az összes mezőt, bekapcsolhatja a manuális bejegyzés kapcsolót, hogy megjelenjenek. További információért lásd: Event Hubs-kapcsolati sztring beszerzése.

Miután beállította az Event Hubs hitelesítő adatait, és kiválasztotta a Csatlakozás lehetőséget, manuálisan is hozzáadhat mezőket a + Mező hozzáadása paranccsel, ha ismeri a mezőneveket. Másik lehetőségként automatikusan észlelheti a mezőket és adattípusokat a bejövő üzenetek mintája alapján, és kiválaszthatja az Automatikus észlelés mezőket. A fogaskerék ikon kiválasztásával szükség esetén szerkesztheti a hitelesítő adatokat.

Amikor streamelési adatfolyamok észlelik a mezőket, láthatja őket a listában. A bejövő üzenetek élő előnézete is látható a Diagram nézet Adatelőnézet táblájában.

A mezőneveket bármikor szerkesztheti, vagy eltávolíthatja vagy módosíthatja az adattípust, ha az egyes mezők mellett további beállításokat (...) választ. A beágyazott mezőket kibonthatja, kijelölheti és szerkesztheti a bejövő üzenetekből, ahogyan az az alábbi képen is látható.

Azure IoT Hub

Az IoT Hub egy felhőben üzemeltetett felügyelt szolgáltatás. Központi üzenetközpontként szolgál az IoT-alkalmazások és a csatlakoztatott eszközök közötti kommunikációhoz mindkét irányban. Több millió eszközt és azok háttérmegoldásait megbízhatóan és biztonságosan csatlakoztathatja. Szinte bármilyen eszköz csatlakoztatható egy IoT Hubhoz.

Az IoT Hub konfigurációja a közös architektúra miatt hasonló az Event Hubs-konfigurációhoz. Vannak azonban bizonyos különbségek, beleértve azt is, hogy hol található a beépített végponthoz tartozó, Event Hubs-kompatibilis kapcsolati sztring. További információ: Eszközről felhőbe irányuló üzenetek olvasása a beépített végpontról.

Miután beillesztette a beépített végpont kapcsolati karakterláncát, az IoT Hubból érkező mezők kiválasztásával, hozzáadásával, automatikus felismerésével és szerkesztésével kapcsolatos összes funkció megegyezik az Event Hubsban megszokottal. A hitelesítő adatokat a fogaskerék ikon kiválasztásával is szerkesztheti.

Tipp

Ha hozzáfér az Event Hubshoz vagy az IoT Hubhoz a szervezete Azure-portálján, és azt a streaming adatfolyam bemeneteként szeretné használni, a kapcsolati sztringeket a következő helyeken találja meg:

Event Hubs esetén:

1. Az Elemzés szakaszban válassza a(z) Minden szolgáltatás>Event Hubs lehetőséget.
2. Válassza az Event Hubs Névtér>entitások/Event Hubs lehetőséget, majd válassza ki az eseményközpont nevét.
3. A Megosztott hozzáférési szabályzatok listában válasszon ki egy szabályzatot.
4. Válassza a Másolás a vágólapra lehetőséget a Kapcsolati karakterlánc – elsődleges kulcs mező mellett.

IoT Hub esetén:

1. Az Internetes dolgok szakaszban válassza az Összes szolgáltatás>IoT Hubs elemet.
2. Válassza ki azt az IoT Hubot, amelyhez csatlakozni szeretne, majd válassza a beépített végpontokat.
3. Válassza a Másolás vágólapra lehetőséget az Event Hubs-kompatibilis végpont mellett.

Amikor streamadatokat használ az Event Hubsból vagy az IoT Hubról, a streamelési adatfolyamban a következő metaadat-időmezőkhöz férhet hozzá:

• EventProcessedUtcTime: Az esemény feldolgozásának dátuma és időpontja.
• EventEnqueuedUtcTime: Az esemény fogadásának dátuma és időpontja.

Egyik mező sem jelenik meg a bemeneti előnézetben. Ezeket manuálisan kell hozzáadnia.

Blobtároló

Az Azure Blob Storage a Microsoft felhőalapú objektumtárolási megoldása. A Blob Storage nagy mennyiségű strukturálatlan adat tárolására van optimalizálva. A strukturálatlan adatok olyan adatok, amelyek nem követnek egy adott adatmodellt vagy -definíciót, például szöveges vagy bináris adatok.

Az Azure Blobokat streamelési vagy referenciabemenetként is használhatja. A streamelési blobok másodpercenként ellenőrzik a frissítéseket. A streamelési bloboktól eltérően a referenciablobok csak a frissítés elején töltődnek be. A statikus adatok várhatóan nem változnak, és a statikus adatokra vonatkozó ajánlott korlát 50 MB vagy kevesebb.

A Power BI arra számít, hogy a referenciablobok a streamelési források mellett, például JOIN-on keresztül is használhatók lesznek. Ezért egy referenciablobot tartalmazó streamelési adatfolyamnak streamelési forrással is rendelkeznie kell.

Az Azure Blobs konfigurációja kissé eltér az Azure Event Hubs-csomópontok konfigurációitól. Az Azure Blob kapcsolati karakterláncának megkereséséhez lásd: Fiókhozzáférési kulcsok megtekintése.

A Blob kapcsolati sztring megadása után meg kell adnia a tároló nevét. Az adatfolyam forrásaként beállítani kívánt fájlok eléréséhez meg kell adnia a könyvtár elérési útvonalmintáját is.

A streamelési blobok esetében a címtár elérési útjának mintája várhatóan dinamikus érték lesz. A dátumnak a blob fájlútvonalának részét kell képeznie – {date} néven hivatkozva. Ezenkívül az elérési út mintájában lévő csillag (*) (például {date}/{time}/*.json) nem támogatott.

Ha például van egy ExampleContainer nevű blobja, amelyben beágyazott .json fájlokat tárol, ahol az első szint a létrehozás dátuma, a második szint pedig a létrehozás órája (ééé-hh-é-nn/ó), akkor a tároló bemenete az "ExampleContainer" lesz. A címtár elérési útja a következő lenne: "{date}/{time}", ahol módosíthatja a dátum- és időmintát.

Miután a blob csatlakozott a végponthoz, az Azure Blobból érkező mezők kiválasztására, hozzáadására, automatikus megadására és szerkesztésére szolgáló összes funkció ugyanaz, mint az Event Hubsban. A hitelesítő adatokat a fogaskerék ikon kiválasztásával is szerkesztheti.

A valós idejű adatok használatakor gyakran az adatok tömörülnek, az azonosítók pedig az objektumot jelölik. A blobok lehetséges használati esete lehet a streamelési források referenciaadatai is. A referenciaadatok segítségével statikus adatokat csatlakoztathat streamelési adatokhoz, így gazdagíthatja a streameket elemzés céljából. Egy gyors példa arra, ha ez a funkció hasznos lenne, ha érzékelőket telepítene különböző áruházakba annak mérésére, hogy egy adott időpontban hányan lépnek be az áruházba. Az érzékelő azonosítóját általában egy statikus táblához kell csatlakoztatni, hogy jelezze, melyik részlegtárban és melyik helyen található az érzékelő. A referenciaadatok segítségével a betöltési fázisban összekapcsolhatja ezeket az adatokat, így könnyen áttekinthető, hogy melyik tárolóban van a legnagyobb a felhasználók kimenete.

Megjegyzés

Egy streamelési adatfolyam-feladat másodpercenként lekéri az adatokat az Azure Blob Storage-ból vagy az ADLS Gen2-bemenetből, ha a blobfájl elérhető. Ha a blobfájl nem érhető el, exponenciális visszalépés történik, amely legfeljebb 90 másodperces késleltetéssel jár.

Adattípusok

A streamelési adatfolyamok mezőinek elérhető adattípusai a következők:

• DateTime: Dátum és idő mező ISO formátumban
• Lebegőpontos: Decimális szám
• Int: Egész szám
• Rekord: Több rekordot tartalmazó beágyazott objektum
• String: Szöveg

Fontos

A streambemenethez kiválasztott adattípusok fontos hatással vannak a streamelési adatfolyamra. Az adatfolyamban a lehető leghamarabb válassza ki az adattípust, hogy később ne kelljen leállítania a módosításokat.

Streamelési adatátalakítás hozzáadása

A streamelési adatátalakítások eredendően eltérnek a kötegelt adatátalakításoktól. Szinte minden streamelési adat rendelkezik egy időösszetevővel, amely hatással van az adat-előkészítési feladatokra.

Ha streamelési adatátalakítást szeretne hozzáadni az adatfolyamhoz, válassza az átalakítás ikonját a menüszalagon az átalakításhoz. A megfelelő kártya megjelenik a diagramnézetben. Miután kiválasztja, megjelenik az adott átalakításhoz tartozó oldalsó panel, ahol konfigurálhatja.

2021 júliusától a streamelési adatfolyamok a következő streamelési átalakításokat támogatják.

Szűrő

A Szűrőátalakítással szűrheti az eseményeket a bemenet egyik mezőjének értéke alapján. Az adattípustól (számtól vagy szövegtől) függően az átalakítás megőrzi a kijelölt feltételnek megfelelő értékeket.

Megjegyzés

Minden kártyán látni fogja az átalakítás előkészítéséhez szükséges további tudnivalókat. Ha például új kártyát ad hozzá, megjelenik egy "Beállítás szükséges" üzenet. Ha hiányzik egy csomópont-összekötő, "Hiba" vagy "Figyelmeztetés" üzenet jelenik meg.

Mezők kezelése

A Mezők kezelése átalakítással bemenetből vagy más átalakításból származó mezőket vehet fel, távolíthat el vagy nevezhet át. Az oldalsó panel beállításai lehetővé teszik, hogy új mezőt adjon hozzá a Mező hozzáadása lehetőség kiválasztásával, vagy egyszerre az összes mezőt hozzáadja.

Tipp

A kártya konfigurálása után a diagramnézet bepillantást enged a kártyán belüli beállításokba. Az előző kép Mezőkezelés területén például láthatja az első három felügyelt mezőt és a hozzájuk rendelt új neveket. Minden kártya rendelkezik az ahhoz kapcsolódó információkkal.

Összesítés

Az Összesítés átalakítással kiszámíthat egy összesítést (Összeg, Minimum, Maximum vagy Átlag) minden alkalommal, amikor egy új esemény egy adott időszakban történik. Ez a művelet azt is lehetővé teszi, hogy az adatok egyéb dimenziói alapján szűrje vagy szeletelje az összesítést. Egy vagy több aggregáció is lehet ugyanabban az átalakításban.

Aggregáció hozzáadásához válassza az átalakítás ikont. Ezután csatlakoztassa a bemenetet, jelölje ki az aggregációt, vegyen fel bármilyen szűrő- vagy szeletdimenziót, és válassza ki az összesítés kiszámításának időtartamát. Ez a példa kiszámítja az útdíj összegét azon szövetségi állam szerint, ahonnan a jármű származik, az elmúlt 10 másodpercben.

Ha egy másik aggregációt szeretne hozzáadni ugyanahhoz az átalakításhoz, válassza az Összesítő függvény hozzáadása lehetőséget. Ne feledje, hogy a szűrő vagy a szeletelő a transzformáció összes aggregációjára vonatkozik.

Csatlakozás

Az Illesztés átalakítás használatával két bemenet eseményeit egyesítheti a kiválasztott mezőpárok alapján. Ha nem jelöl ki mezőpárt, az illesztés alapértelmezés szerint az idő alapján történik. Az alapértelmezett érték az, ami miatt ez az átalakítás eltér egy kötegtől.

A normál illesztésekhez hasonlóan az illesztési logikához is különböző lehetőségek állnak rendelkezésre:

• Belső illesztés: Csak olyan rekordokat vegyen fel mindkét táblából, ahol a pár egyezik. Ebben a példában a rendszámtábla mindkét bemenetnek megfelel.
• Bal oldali külső illesztés: A bal oldali (első) tábla összes rekordját belefoglalja, és csak a második rekordot, amely megfelel a mezőpárnak. Ha nincs egyezés, a második bemenet mezői üresek lesznek.

Az illesztés típusának kiválasztásához válassza az oldalpanelen az előnyben részesített típus ikonját.

Végül válassza ki, hogy az illesztés milyen időtartamban legyen kiszámítva. Ebben a példában az illesztés az utolsó 10 másodpercet vizsgálja. Ne feledje, hogy minél hosszabb az időszak, annál ritkábban jön ki a kimenet– és minél több feldolgozási erőforrást használ az átalakításhoz.

Alapértelmezés szerint mindkét tábla összes mezőjét tartalmazza a rendszer. A kimenet bal (első csomópont) és jobb (második csomópont) előtagja segít megkülönböztetni a forrást.

Csoportosítás szempontja:

A Csoportosítás transzformációt használhatja arra, hogy egy adott időablakon belül az összes eseményre vonatkozó aggregációkat számítson ki. Egy vagy több mező értékei szerint csoportosíthat. Hasonló az Összesítés átalakításhoz, de további lehetőségeket kínál az összesítésekhez. Emellett összetettebb időablak-beállításokat is tartalmaz. Az Összesítéshez hasonlóan átalakításonként több aggregációt is hozzáadhat.

Az átalakítás során elérhető összesítések a következők: Átlag, Darabszám, Maximum, Minimum, Percentilis (folyamatos és diszkrét), Szórás, Összeg és Variancia.

Az átalakítás konfigurálása:

1. Válassza ki az előnyben részesített összesítést.
2. Válassza ki az összesíteni kívánt mezőt.
3. Jelöljön ki egy választható csoportosítási mezőt, ha egy másik dimenzió vagy kategória (például Állam) összesített számítását szeretné lekérni.
4. Válassza ki a kívánt függvényt az időablakokhoz.

Ha egy másik aggregációt szeretne hozzáadni ugyanahhoz az átalakításhoz, válassza az Összesítő függvény hozzáadása lehetőséget. Ne feledje, hogy a Csoportosítás mező és az ablakozási függvény az átalakítás összes aggregációjára vonatkoznak.

Az időablak végének időbélyege az átalakítási kimenet részeként jelenik meg referenciaként.

A cikk egy későbbi szakasza ismerteti az átalakításhoz rendelkezésre álló időkeretek típusát.

Unió

Az Uniós átalakítással összekapcsolhat két vagy több bemenetet, hogy megosztott mezőkkel (ugyanazzal a névvel és adattípussal) rendelkező eseményeket vegyen fel egy táblába. A nem egyező mezők el lesznek dobva, és nem szerepelnek a kimenetben.

Időablak-függvények beállítása

Az időablakok a streamelési adatok egyik legösszetettebb fogalmai. Ez a koncepció a streamelemzés középpontjában helyezkedik el.

A streamelési adatfolyamokban az adatok összesítésekor időablakokat adhat meg a Group by transzformáció egyik lehetőségeként.

Megjegyzés

Ne feledje, hogy az ablakozási műveletek összes kimeneti eredménye az időkeret végén lesz kiszámítva. Az ablak kimenete egyetlen esemény lesz, amely az összesítő függvényen alapul. Ez az esemény az ablak végének időbélyegével fog rendelkezni, és az összes ablakfüggvény rögzített hosszúságú lesz.

Ötféle időablak közül választhat: bukdácsoló, ugró, csúszó, munkamenet- és pillanatképablak.

Átfedésmentes ablak

A bukdácsoló ablak a leggyakoribb időablaktípus. Az egymást követő időablakok fő jellemzője, hogy ismétlődnek, azonos időtartamúak, és nem fedik át egymást. Egy esemény nem tartozhat egynél több ugróablakhoz.

Amikor streaming adatfolyamokban egy ugróablakot állít be, meg kell adnia az ablak időtartamát (ami ebben az esetben minden ablaknál azonos). Megadhat opcionális eltolást is. Alapértelmezés szerint az egymást nem átfedő időablakok az ablak végét tartalmazzák, az elejét pedig kizárják. Ezzel a paraméterel módosíthatja ezt a viselkedést, és belefoglalhatja az eseményeket az ablak elejébe, és kizárhatja azokat a végén.

Felugró ablak

Az ugró ablakok rögzített időközönként lépnek előre az időben. Úgy is felfoghatja őket, mint egymást átfedő, gördülő ablakokat, amelyek az ablak méreténél gyakrabban is létrejöhetnek. Az események egy ugró ablak esetén egynél több eredménykészlethez is tartozhatnak. Ha azt szeretné, hogy egy csúszó ablak megegyezzen egy bukdácsoló ablakkal, az ugrásméretet az ablakmérettel azonosra állíthatja.

Amikor egy átugró ablakot állít be streamelési adatfolyamokban, meg kell adnia az ablak időtartamát (ugyanúgy, mint a leugró ablakok esetében). Meg kell adnia az ugrás méretét is, amely azt jelzi, hogy a streamelési adatfolyamok milyen gyakran számítják ki az összesítést a megadott időtartamra.

Az eltolási paraméter az emelőablakokban is elérhető, ugyanazért, mint a bukóablakokban. Meghatározza az események belefoglalásának és kizárásának logikáját az ugró ablak elejére és végére vonatkozóan.

Csúszóablak

A tolóablakok a csúszástól vagy az emelőablakoktól eltérően csak olyan időpontokra számítják ki az aggregációt, amikor az ablak tartalma ténylegesen megváltozik. Amikor egy esemény belép vagy kilép az ablakon, a rendszer kiszámítja az összesítést. Tehát minden ablaknak van legalább egy eseménye. A felugró ablakokhoz hasonlóan az események több tolóablakhoz is tartozhatnak.

Egy tolóablakhoz az egyetlen paraméter az időtartam, mivel maguk az események határozzák meg, hogy mikor indul el az ablak. Nincs szükség eltoláslogikára.

Munkamenet ablaka

A munkamenetablakok a legösszetettebbek. Csoportosítják a hasonló időpontokban érkező eseményeket, kiszűrve azokat az időszakokat, amikor nincsenek adatok. Ebben az ablakban meg kell adnia a következőt:

• Időtúllépés: mennyi ideig kell várni, ha nincsenek új adatok.
• Maximális időtartam: az összesítés által kiszámított leghosszabb idő, ha az adatok folyamatosan érkeznek.

Igény szerint partíciót is definiálhat.

Az átalakításhoz közvetlenül az oldalsó panelen állíthat be munkamenetablakot. Ha megad egy partíciót, az összesítés csak ugyanazon kulcshoz csoportosítja az eseményeket.

Pillanatkép ablak

A pillanatképablakok az azonos időbélyeggel rendelkező eseményeket csoportosítják. A többi ablaktól eltérően a pillanatképek nem igényelnek paramétereket, mivel a rendszerből származó időt használják.

Kimenetek meghatározása

A bemenetek és átalakítások beállítása után itt az ideje egy vagy több kimenet definiálása. 2021 júliusától a streamelési adatfolyamok csak a Power BI-táblákat támogatják.

Ez a kimenet egy adatfolyamtábla (vagyis egy entitás), amellyel jelentéseket hozhat létre a Power BI Desktopban. A működéshez össze kell kapcsolnia az előző lépés csomópontjait az éppen létrehozott kimenettel. Ezután nevezze el a táblát.

Miután csatlakozott az adatfolyamhoz, ez a táblázat elérhető lesz a jelentésekhez valós időben frissített vizualizációk létrehozásához.

Adatelőnézet és hibák

A streaming adatfolyamok olyan eszközöket biztosítanak, amelyekkel megtervezheti, elháríthatja a hibákat, és kiértékelheti a streaming adatokhoz készült elemzési folyamata teljesítményét.

Élő adatok előnézete bemenetekhez

Amikor egy eseményközponthoz vagy IoT Hubhoz csatlakozik, és kiválasztja annak kártyáját a diagram nézetben (az Adatok előnézete lapon), élő előnézetet kap az adatokról, ha az összes alábbi igaz:

• Az adatok leküldése folyamatban van.
• A bemenet megfelelően van konfigurálva.
• Mezők lettek hozzáadva.

Az alábbi képernyőképen látható módon, ha valamilyen konkrét dolgot szeretne látni vagy részletezni, szüneteltetheti az előnézetet (1). Vagy újrakezdheti, ha elkészült.

Egy adott rekord részleteit (a tábla egy "celláját") is megtekintheti, ha kijelöli, majd a Részletek megjelenítése vagy a Részletek elrejtése (2) lehetőséget választja. A képernyőképen egy beágyazott objektum részletes nézete látható egy rekordban.

Statikus előzetes verzió átalakításokhoz és kimenetekhez

Miután hozzáadta és beállította a diagram nézet lépéseit, a statikus adatok gombra kattintva tesztelheti a viselkedésüket.

Ezt követően a streamelési adatfolyamok kiértékelik a helyesen konfigurált összes átalakítást és kimenetet. A streamelési adatfolyamok ezután a statikus adatok előnézetében jelenítik meg az eredményeket, ahogyan az az alábbi képen is látható.

Az előzetes verzió frissítéséhez válassza a Statikus előnézet frissítése (1) lehetőséget. Ha ezt teszi, a streamelési adatfolyamok új adatokat vesznek fel a bemenetből, és újra kiértékelik az összes átalakítást és kimenetet az esetlegesen végrehajtott frissítésekkel. A Részletek megjelenítése vagy elrejtése lehetőség is elérhető (2).

Szerzői hibák

Ha szerzői hibák vagy figyelmeztetések jelennek meg, a Szerzői hibák lap (1) felsorolja őket az alábbi képernyőképen látható módon. A lista tartalmazza a hiba vagy figyelmeztetés részleteit, a kártya típusát (bemenet, átalakítás vagy kimenet), a hibaszintet, valamint a hiba vagy figyelmeztetés leírását (2). A hibák vagy figyelmeztetések kiválasztásakor a megfelelő kártya lesz kiválasztva, és megnyílik a konfigurációs oldalpanel a szükséges módosítások elvégzéséhez.

Futtatókörnyezeti hibák

Az előnézet utolsó elérhető lapja a futtatókörnyezeti hibák (1), ahogyan az alábbi képernyőképen látható. Ez a lap felsorolja a streamelési adatfolyam betöltésének és elemzésének folyamatával kapcsolatos hibákat az indítás után. Előfordulhat például, hogy futásidejű hibaüzenet jelenik meg, ha egy üzenet sérült, és az adatfolyam nem tudta betölteni és végrehajtani a definiált átalakításokat.

Mivel előfordulhat, hogy az adatfolyamok hosszú ideig futnak, ez a lap lehetővé teszi a szűrést időtartomány szerint, valamint a hibák listáját, és szükség esetén frissítheti (2).

A streamelő adatfolyamok beállításainak módosítása

A hagyományos adatfolyamokhoz hasonlóan a streamelési adatfolyamok beállításai a tulajdonosok és a szerzők igényeitől függően módosíthatók. Az alábbi beállítások egyediek a streamelt adatfolyamok esetében. A többi beállítás esetében a két adatfolyamtípus közötti megosztott infrastruktúra miatt feltételezheti, hogy a használat ugyanaz.

• Frissítési előzmények: Mivel a streamelési adatfolyamok folyamatosan futnak, a frissítési előzmények csak az adatfolyam indításáról, megszakításáról vagy sikertelenségéről (adott esetben részletekkel és hibakódokkal) kapcsolatos információkat tartalmaznak. Ezek az információk hasonlóak a normál adatfolyamok esetében megjelenő adatokhoz. Ezekkel az információkkal elháríthatja a problémákat, vagy a Power BI támogatási szolgálatának rendelkezésére bocsáthatja a kért részleteket.

• Adatforrás hitelesítő adatai: Ez a beállítás az adott streamelési adatfolyamhoz konfigurált bemeneteket jeleníti meg.

• Továbbfejlesztett számítási motorbeállítások: A streamelési adatfolyamoknak a továbbfejlesztett számítási motorra van szükségük a valós idejű vizualizációk biztosításához, ezért ez a beállítás alapértelmezés szerint be van kapcsolva, és nem módosítható.

• Megőrzés időtartama: Ez a beállítás a streamelési adatfolyamokra vonatkozik. Itt megadhatja, hogy mennyi ideig szeretné megőrizni a valós idejű adatokat a jelentésekben való megjelenítéshez. Az előzményadatok alapértelmezés szerint az Azure Blob Storage-ban lesznek mentve. Ez a beállítás az adatok valós idejű oldalára (gyakori elérésű tárolás) vonatkozik. A minimális érték 1 nap vagy 24 óra.

  Fontos

  Az ebben a megőrzési időtartamban tárolt forró adatok mennyisége közvetlenül befolyásolja a valós idejű vizualizációk teljesítményét, amikor ezekre az adatokra épülő jelentéseket készít. Minél nagyobb a megőrzési idő, annál nagyobb hatással lehet a jelentések valós idejű vizualizációira az alacsony teljesítmény. Ha előzményelemzést kell végeznie, használja a streamelt adatfolyamokhoz biztosított hideg tárterületet.

Streamelési adatfolyam futtatása és szerkesztése

Miután mentette és konfigurálta a streamelési adatfolyamot, minden készen áll a futtatásra. Ezután megkezdheti az adatok Power BI-ba való betöltését a definiált streamelemzési logikával.

Streamelési adatfolyam futtatása

A streamelési adatfolyam elindításához először mentse az adatfolyamot, és lépjen arra a munkaterületre, ahol létrehozta. Vigye az egérmutatót a streamelési adatfolyam fölé, és válassza a megjelenő lejátszás gombot. Az előugró üzenet azt jelzi, hogy a streamelési adatfolyam elindult.

Megjegyzés

Akár öt percet is igénybe vehet, mire az adatok beérkezése megkezdődik, és Ön látni kezdi a beérkező adatokat, hogy jelentéseket és irányítópultokat hozhasson létre a Power BI Desktopban.

Streamelési adatfolyam szerkesztése

Amíg egy streamelési adatfolyam fut, nem szerkeszthető. Egy futó állapotú streamelési adatfolyamba azonban bemehet, és megtekintheti az adatfolyamra épülő elemzési logikát.

Amikor egy futó adatfolyamba lép, a rendszer letiltja az összes szerkesztési lehetőséget, és megjelenik egy üzenet: "Az adatfolyam nem szerkeszthető futás közben. Állítsa le az adatfolyamot, ha folytatni szeretné." Az adatok előnézete is le van tiltva.

A streaming adatfolyam szerkesztéséhez először le kell állítania azt. A leállított adatfolyam hiányzó adatokat eredményez.

Egy streaming adatfolyam futása közben csak a Futásidejű hibák fül érhető el, ahol nyomon követheti az adatfolyam viselkedését, beleértve az eldobott üzeneteket és a hasonló helyzeteket is.

Az adatfolyam szerkesztésekor fontolja meg az adattárolást

Adatfolyam szerkesztésekor figyelembe kell vennie más szempontokat is. A normál adatfolyamok sémájának változásaihoz hasonlóan, ha módosít egy kimeneti táblát, a már leküldött és a Power BI-ba mentett adatokat elveszíti. A felület egyértelmű tájékoztatást nyújt a streamelési adatfolyam ezen módosításainak következményeiről, valamint a mentés előtt végrehajtott módosításokról.

Ezt egy példa szemlélteti a legjobban. Az alábbi képernyőképen az az üzenet látható, amely akkor jelenik meg, amikor oszlopot ad hozzá az egyik táblához, megváltoztatja egy második tábla nevét, és egy harmadik táblát ugyanúgy hagy, mint korábban.

Ebben a példában a séma- és névmódosításokat tartalmazó táblákban már mentett adatok törlődnek a módosítások mentésekor. Az azonos maradó táblázat esetében lehetősége van törölni a régi adatokat, és elölről kezdeni, vagy menteni a későbbi elemzéshez az új adatokkal együtt.

Ezeket a árnyalatokat tartsa szem előtt a streamelési adatfolyam szerkesztésekor, különösen akkor, ha később rendelkezésre álló előzményadatokra van szüksége a további elemzéshez.

Folyamatos adatfolyam fogyasztása

Miután a streaming adatfolyam fut, megkezdheti a tartalom létrehozását a streaming adatai alapján. A valós időben frissített jelentések létrehozásához nincs strukturális változás ahhoz képest, hogy mit kell tennie. Figyelembe kell venni néhány árnyalatot és frissítést, hogy kihasználhassa az adatstreamelési adatok ilyen típusú előkészítésének előnyeit.

Adattárolás beállítása

Ahogy korábban említettük, a streamelési adatfolyamok az alábbi két helyen mentik az adatokat. Ezeknek a forrásoknak a használata attól függ, hogy milyen típusú elemzést szeretne elvégezni.

• Gyakori elérésű tárolás (valós idejű elemzés):Mivel a streamelési adatfolyamokból származó adatok kerülnek a Power BI-ba, az adatok egy gyakori elérésű helyen lesznek tárolva, ahol valós idejű vizualizációkhoz férhet hozzá. A tárterületen tárolt adatok mennyiségének függ a streamelési adatfolyam beállításaiban megadott adatmegőrzési időtartamtól . Az alapértelmezett (és minimum) 24 óra.
• Hideg tárolás (előzményelemzés):: A Power BI-ban minden olyan időszak, amely nem esik bele a megőrzési időtartamhoz megadott időtartamba, a Rendszer a Power BI-ban tárolja a hideg tárolásba (blobok) a felhasználáshoz, ha szükséges.

Megjegyzés

A két adattárhely között átfedés van. Ha mindkét helyet együtt kell használnia (például napi százalékos változás), előfordulhat, hogy deduplikálnia kell a rekordokat. Ez az éppen készített időintelligencia-számításoktól és a megőrzési szabályzattól függ.

Kapcsolódás a streaming adatfolyamokhoz a Power BI Desktopból

A Power BI Desktop egy Adatfolyamok nevű összekötőt kínál az Ön számára. A streamelési adatfolyamok összekötőjének részeként két tábla jelenik meg, amelyek megfelelnek a korábban leírt adattárnak.

Az adataihoz való csatlakozáshoz a folyamatos átviteli adatfolyamok esetén:

1. Lépjen az Adatok lekérése menüpontra, válassza a Power Platform lehetőséget, majd az Adatfolyamok összekötőt.

   

2. Jelentkezzen be Power BI-hitelesítő adataival.

3. Munkaterületek kiválasztása. Keresse meg azt, amelyik a streamelési adatfolyamot tartalmazza, és válassza ki az adatfolyamot. (Ebben a példában a streamelési adatfolyam neve Útdíj.)

4. Vegye figyelembe, hogy az összes outputtábla kétszer jelenik meg: külön egy a streamingadatokhoz (forró), és külön egy az archivált adatokhoz (hideg). Megkülönböztetheti őket a táblanevek után hozzáadott címkék és az ikonok alapján.

   

5. Csatlakozzon a streamelési adatokhoz. Az archivált adatok esete ugyanez, csak import módban érhető el. Jelölje ki a Streaming és Hot címkéket tartalmazó táblákat, majd válassza a Betöltés lehetőséget.

   

6. Amikor a rendszer arra kéri, hogy válasszon tárolási módot, válassza a DirectQuery lehetőséget, ha a cél valós idejű vizualizációk létrehozása.

   

Mostantól vizualizációkat, mértékeket és egyebeket hozhat létre a Power BI Desktopban elérhető funkciókkal.

Megjegyzés

A szokásos Power BI-adatfolyam-összekötő továbbra is elérhető, és két kikötéssel fog működni a streamelési adatfolyamokkal:

• Csak forró tárolóhoz enged csatlakozni.
• Az összekötő adatelőnézete nem működik streamelési adatfolyamokkal.

Az automatikus oldalfrissítés bekapcsolása valós idejű vizualizációkhoz

Miután elkészült a jelentéssel, és hozzáadta az összes megosztani kívánt tartalmat, az egyetlen lépés a vizualizációk valós idejű frissítésének biztosítása. Használhatja az automatikus oldalfrissítés nevű funkciót. Ez a funkció lehetővé teszi a vizualizációk DirectQuery-forrásból való frissítését akár egy másodpercig is.

A funkcióval kapcsolatos további információkért lásd : Automatikus oldalfrissítés a Power BI-ban. Ez a cikk információkat tartalmaz a használatról, a beállításáról, valamint arról, hogy miként léphet kapcsolatba a rendszergazdával, ha problémát tapasztal. A beállítás alapjai a következők:

1. Lépjen arra a jelentésoldalra, ahol valós időben szeretné frissíteni a vizualizációkat.

2. Töröljön minden vizuális elemet a lapról. Ha lehetséges, válassza ki a lap hátterét.

3. Nyissa meg a Formátum panelt (1), és kapcsolja be a Lapfrissítést (2).

   

4. Állítsa be a kívánt gyakoriságot (legfeljebb másodpercenként, ha a rendszergazda engedélyezte).

   

5. Egy valós idejű jelentés megosztásához először tegye közzé újra a Power BI szolgáltatásban. Ezután beállíthatja az adatfolyam hitelesítő adatait a szemantikai modellhez és a megosztáshoz.

Tipp

Ha a jelentés nem frissül olyan gyorsan, amennyire szüksége van, vagy valós időben, ellenőrizze a dokumentációban az automatikus oldalfrissítést. Kövesse a gyakori kérdéseket és a hibaelhárítási utasításokat, hogy megtudja, miért fordulhat elő ez a probléma.

Szempontok és korlátozások

Általános korlátozások

• Streamelési adatfolyamok létrehozásához és futtatásához Power BI Premium-előfizetésre (kapacitásra vagy PPU-ra) van szükség.
• Munkaterületenként csak egy adatfolyamtípus engedélyezett.
• A normál és streamelt adatfolyamok összekapcsolása nem lehetséges.
• Az A3-nál kisebb kapacitások nem teszik lehetővé a streamelési adatfolyamok használatát.
• Ha az adatfolyamok vagy a továbbfejlesztett számítási motor nincs engedélyezve egy bérlőben, nem hozhat létre vagy futtathat streamelési adatfolyamokat.
• A tárfiókhoz csatlakoztatott munkaterületek nem támogatottak.
• Minden streamelési adatfolyam másodpercenként legfeljebb 1 MB átviteli sebességet biztosíthat.

Elérhetőség

A streamelési adatfolyamok előnézete nem érhető el a következő régiókban:

• Közép-India
• Észak-Németország
• Kelet-Norvégia
• Nyugat-Norvégia
• Egyesült Arab Emírségek középső régiója
• Dél-Afrika északi régiója
• Dél-Afrika nyugati régiója
• Észak-Svájc
• Nyugat-Svájc
• Délkelet-Brazília

Licencelés

A bérlőnként engedélyezett streamelési adatfolyamok száma a használt licenctől függ:

• Normál kapacitások esetén a következő képlet segítségével számítsa ki a kapacitásban engedélyezett streamelési adatfolyamok maximális számát:

  A kapacitásonkénti streaming adatfolyamok maximális száma = a kapacitás vCore-jainak száma × 5

  A P1 például 8 vCore-ral rendelkezik: 8 * 5 = 40 streaming adatfolyam.

• Felhasználónkénti Premium esetén felhasználónként egy streamelési adatfolyam engedélyezett. Ha egy másik felhasználó streamelési adatfolyamot szeretne használni egy PPU-munkaterületen, pPU-licencre is szüksége van.

Adatfolyam-létrehozás

Streamelési adatfolyamok létrehozásakor vegye figyelembe az alábbi szempontokat:

• A streamelési adatfolyamok tulajdonosa csak módosításokat végezhet, és csak akkor végezhet módosításokat, ha az adatfolyam nem fut.
• A streamelési adatfolyamok nem érhetők el a Saját munkaterületen.

Csatlakozás a Power BI Desktopból

A hideg tároláshoz csak a Power BI Desktop 2021. júliusi frissítésétől elérhető Adatfolyam-összekötő használatával férhet hozzá. A korábbi Power BI-adatfolyam-összekötő csak a folyamatosan beérkező adatokhoz használt forró tárolóhoz való kapcsolódást támogatja. Az összekötő adatelőnézete nem működik.

Kapcsolódó tartalom

Ez a cikk áttekintést nyújtott az önkiszolgáló streamelési adatok streamelési adatfolyamok használatával történő előkészítéséről. Az alábbi cikkekből megtudhatja, hogyan teszteli ezt a képességet, és hogyan használhat más streamadat-funkciókat a Power BI-ban:

• IoT-megoldás létrehozása a Stream Analytics használatával
• Raspberry Pi online szimulátor csatlakoztatása az Azure IoT Hubhoz (Node.js)
• Valós idejű streamelés a Power BI-ban
• Automatikus oldalfrissítés a Power BI-ban