Megjegyzés
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhat bejelentkezni vagy módosítani a címtárat.
Az oldalhoz való hozzáféréshez engedély szükséges. Megpróbálhatja módosítani a címtárat.
Ez az oktatóanyag bemutatja, hogyan használható a Stream Analytics kódszerkesztője a valós idejű adatfolyamok összesítéseinek kiszámítására és az Azure Synapse Analyticsben való tárolására.
Ebben az oktatóanyagban az alábbiakkal fog megismerkedni:
- Eseménygenerátor üzembe helyezése, amely adatokat küld az eseményközpontba
- Stream Analytics-feladat létrehozása kódszerkesztő nélkül
- Bemeneti adatok és séma áttekintése
- Jelölje ki a csoportosítandó mezőket, és definiáljon olyan összesítéseket, mint a darabszám
- Az Azure Synapse Analyticset úgy kell konfigurálni, hogy az eredmények oda íródjanak
- Stream Analytics-feladat futtatása
- Adatok megjelenítése a Power BI-ban
Előfeltételek
Mielőtt hozzákezd, végezze el a következő lépéseket:
- Ha nem rendelkezik Azure-előfizetéssel, hozzon létre egy ingyenes fiókot.
- Telepítse a TollApp eseménygenerátort az Azure-ban. Ezen a hivatkozáson üzembe helyezheti a TollApp Azure-sablont. Állítsa a paramétert
interval1 értékre. Ehhez a lépéshez használjon új erőforráscsoportot. - Azure Synapse Analytics-munkaterület létrehozása dedikált SQL-készlettel.
-
Hozzon létre egy táblát
carsummarya dedikált SQL-készlet használatával. Futtassa a következő SQL-szkriptet:CREATE TABLE carsummary ( Make nvarchar(20), CarCount int, times datetime ) WITH ( CLUSTERED COLUMNSTORE INDEX ) ;
Stream Analytics-feladat létrehozása kódszerkesztő nélkül
Keresse meg azt az erőforráscsoportot, amelyben üzembe helyezte a TollApp eseménygenerátort.
Válassza ki az Azure Event Hubs-névteret.
Az Event Hubs névtér lapján válassza az Event Hubs lehetőséget a bal oldali menü Entitások területén.
Válassza ki a példányt
entrystream.A Szolgáltatások szakaszban nyissa meg az Adatok feldolgozása lehetőséget, majd válassza a Kezdés üres vászonsablonnal lehetőséget.
Nevezze el a feladatot
carsummary, és válassza a Létrehozás lehetőséget.Az eseményközpont konfigurációs lapján erősítse meg a következő beállításokat, majd válassza a Csatlakozás lehetőséget.
Fogyasztói csoport esetén válassza a Meglévő használata lehetőséget, majd az Alapértelmezett lehetőséget.
Szerializálási típus esetén ellenőrizze, hogy a JSON van-e kiválasztva.
Hitelesítési mód esetén ellenőrizze, hogy a kapcsolati sztringet használja-e az eseményközponthoz való csatlakozáshoz: Kapcsolati sztring.
Néhány másodpercen belül megjelenik a minta bemeneti adatok és a séma. Dönthet úgy, hogy elveti a mezőket, átnevezi a mezőket, vagy módosítja az adattípusokat.
Válassza a parancssávOn a Műveletek lehetőséget, majd válassza a Csoportosítás szempontja lehetőséget.
Jelölje ki a csoportosítás csempét a vásznon, és csatlakoztassa az event hub csempéjéhez.
Konfigurálja a Csoportosítás csempét a következő tulajdonságok megadásával:
Az összesítés darabszámként.
Mezőként Make, amely a CarModel nevű objektum egy beágyazott mezője.
Válassza a Hozzáadás lehetőséget.
A Beállítások szakaszban:
Válassza a Csoportosítás szempontja lehetőséget, és figyelje meg a csoportosított adatokat a lap alján, az Adatok előnézete lapon.
A parancssávon válassza a Műveletek , majd a Mezők kezelése lehetőséget.
Kapcsolja össze a Csoportosítás szerint és Mezők kezelése elemeket.
A Mezők kezelése oldalon kövesse az alábbi lépéseket:
Válassza az Összes mező hozzáadása lehetőséget a Mezők kezelése konfigurációs lapon.
A mezők mellett válassza a ... lehetőséget, majd a Szerkesztés gombra kattintva nevezze át őket.
Válassza a Kész elemet a Mezők kezelése lapon. A Mezők kezelése lapnak az alábbi képen látható módon kell kinéznie.
Válassza a Mezők kezelése csempét, és tekintse meg a műveletbe áramló adatokat a lap alján az Adatok előnézete lapon.
A parancssávon válassza a Kimenetek, majd a Synapse lehetőséget.
Csatlakoztassa a Synapse csempét a vászon Mezőkezelés csempéjéhez.
A Synapse beállításai lapon kövesse az alábbi lépéseket:
Ha a Feladattárfiók még nincs beállítva, válassza ki az Azure Data Lake Storage-fiókot az erőforráscsoportban. Ez az a tárfiók, amelyet a Synapse SQL használ az adatok adattárházba való betöltéséhez.
Válassza ki azt az Azure-előfizetést, amelyben az Azure Synapse Analytics található.
Válassza ki az előző szakaszban a tábla létrehozásához
carsummaryhasznált dedikált SQL-készlet adatbázisát.Adja meg a hitelesítéshez használt felhasználónevet és jelszót.
Adja meg a tábla nevét a következőképpen
carsummary: .Válassza a Kapcsolódás lehetőséget. A Synapse SQL-táblába írt mintaeredmények láthatók.
Válassza a Synapse csempét , és tekintse meg az Adatok előnézete lapot a lap alján. Láthatók az adatok, amint a dedikált SQL-készletbe áramlanak.
A feladat mentéséhez válassza a Mentés lehetőséget a felső menüszalagon, majd válassza a Start lehetőséget.
A Stream Analytics-feladat indítása lapon válassza a Start lehetőséget a feladat futtatásához.
Ezután megjelenik a kódszerkesztővel létrehozott összes Stream Analytics-feladat listája. És két percen belül a feladat futási állapotba kerül. A lapon a Frissítés gombra kattintva megtekintheti a Létrehozás – Indítás –>> Futtatás állapotváltozását.
Power BI-vizualizáció létrehozása
Töltse le a Power BI Desktop legújabb verzióját.
Használja az Azure Synapse SQL-hez készült Power BI-összekötőt.
Csatlakozzon az adatbázishoz a DirectQuery használatával, és ezzel a lekérdezéssel kérje le az adatokat az adatbázisból
SELECT [Make],[CarCount],[times] FROM [dbo].[carsummary] WHERE times >= DATEADD(day, -1, GETDATE())Váltson az Adatbázis lapra, és adja meg a hitelesítő adatait (felhasználónév és jelszó) az adatbázishoz való csatlakozáshoz és a lekérdezés futtatásához.
Válassza a Betöltés lehetőséget az adatok Power BI-ba való betöltéséhez.
Ezután létrehozhat egy vonaldiagramot a következővel:
- X tengely idő szerint
- Y tengely CarCount-ként
- Jelmagyarázatként tekinthet meg egy diagramot, amelyet közzétehet. Konfigurálhatja az automatikus oldalfrissítést , és beállíthatja 3 percre, hogy valós idejű nézetet kapjon.
További lehetőségek
Az Azure Synapse SQL mellett az SQL Database-t is használhatja kód nélküli szerkesztőkimenetként a streamelési adatok fogadásához. Ezután a Power BI-összekötővel csatlakozhat az SQL-adatbázishoz a DirectQuery használatával a valós idejű irányítópult létrehozásához.
A valós idejű irányítópultot a streamelési adatokkal is létrehozhatja. Az SQL Database kimenetéről további információt az SQL Database átalakítása és betöltése című témakörben talál.
Az erőforrások megtisztítása
- Keresse meg az Event Hubs-példányt, és tekintse meg a Stream Analytics-feladatok listáját a Folyamatadatok szakaszban. Állítsa le a futó feladatokat.
- Lépjen a TollApp eseménygenerátor üzembe helyezésekor használt erőforráscsoportra.
- Válassza az Erőforráscsoport törlése elemet. A törlés megerősítéséhez írja be az erőforráscsoport nevét.
Következő lépések
Ebben az oktatóanyagban létrehozottál egy Stream Analytics-feladatot a kód nélküli szerkesztő használatával, hogy aggregációkat határozz meg és az eredményeket az Azure Synapse Analyticsbe írd. Ezután a Power BI-tal készített egy valós idejű irányítópultot a feladat által létrehozott eredmények megtekintéséhez.