Gyorsindítás: hozzon létre egy Stream Analytics állást a Visual Studio-ban

Ebben a gyorsindításban létrehozhatsz egy Stream Analytics feladatot Azure Stream Analytics eszközök használatával a Visual Studio-hoz. A példafeladat egy IoT Hub-eszközről származó adatfolyamot olvas. Olyan feladatot definiálsz, amely kiszámítja az átlagos hőmérsékletet, ha az érték meghaladja a 27°-ot, és az eredményt megörökítő eseményeket egy új fájlba írja a blob tárolóban.

Prerequisites

Mielőtt belevágnál, győződj meg róla, hogy a következő előfeltételek rendelkezésre állnak.

Megjegyzés:

A legjobb helyi fejlesztési élmény érdekében használja a Stream Analytics-eszközöket a Visual Studio Code-hoz. A Visual Studio 2019 Stream Analytics eszközei (2.6.3000.0 verzió) ismert funkcióhiányokat mutatnak, és további fejlesztéseket nem kapnak. A Visual Studio és a Visual Studio Code eszközei nem támogatják a kelet-kínai, az észak-kínai, a közép- és a németországi északkeleti régióban lévő feladatokat.

A bemeneti adatok előkészítése

Mielőtt meghatároznád a Stream Analytics feladatot, készítsd elő azokat az adatokat, amelyeket később bemenetként konfigurálsz. A bemeneti adatok előkészítéséhez teljesítse a következő lépéseket:

  1. Jelentkezzen be a Azure portalra.

  2. Válassza az>erőforrás-internetének> létrehozása lehetőséget.

  3. Az IoT Hub panelen adja meg a következő információkat:

    Setting Ajánlott érték Leírás
    Subscription <Az ön előfizetése> Válassza ki a használni kívánt Azure-előfizetést.
    Erőforráscsoport asaquickstart-resourcegroup Válassza az Új létrehozása lehetőséget , és adjon meg egy új erőforráscsoportnevet a fiókjához.
    IoT Hub neve MyASAIoTHub Válassz nevet az IoT hubodnak.
    Régió <Válaszd ki azt a régiót, ami a legközelebb van a felhasználóidhoz> Válassz egy földrajzi helyet, ahol az IoT központot tárolhatod. Használja a felhasználókhoz legközelebbi helyet.
    Kategória Ingyenes Ebben a rövid útmutatóban válassza az Ingyenes lehetőséget, ha az továbbra is elérhető az előfizetésében. Ha az ingyenes szint nem érhető el, válassza ki a legalacsonyabb elérhető szintet. További információkért lásd az IoT Hub díjszabását.

    Képernyőkép az IoT Hub létrehozása varázslóról az Azure Portalon.

  4. Válassza az Áttekintés + létrehozás lehetőséget. Nézd át az IoT hub adataidat, és válaszd a Létrehozás gombot. Az IoT hubod létrehozása akár pár percet is igénybe vehet. Figyelje az előrehaladást az Értesítések panelen.

  5. A telepítés befejezése után válaszd a Ugrás az erőforráshoz lehetőséget az IoT Hub oldalának megnyitásához.

  6. Az IoT Hub lapon válassza az Eszközök lehetőséget a bal oldali navigációs menü Eszközkezelés területén.

  7. Az Eszközök lapon válassza az eszköztár + Eszköz hozzáadása lehetőséget.

    Képernyőkép az Eszközök lapról, amelyen az Eszköz hozzáadása elem van kijelölve.

  8. Az Eszköz létrehozása lapon adja meg az eszköz nevét, és válassza a Mentés lehetőséget.

    Képernyőkép az Eszköz létrehozása lapról.

  9. Miután létrehoztad az eszközt, nyisd meg az IoT eszközök listájából. Ha még nem látja az eszközt, frissítse a lapot.

    Képernyőkép a létrehozott eszközlistáról.

  10. Másolja ki az elsődleges kapcsolati sztringet , és mentse azt egy jegyzettömbbe, hogy később használhassa.

Blob storage létrehozása

Ebben a részben létrehozol egy Azure Storage fiókot és egy blob konténert, hogy tárold a munkád kimeneti eseményeit.

  1. A bal felső sarokban az Azure Portalon válassza a Erőforrás létrehozása>, Tárhely> és Tárhelyfiók lehetőségeket.

  2. A Tárfiók létrehozása panelen adja meg a tárfiók nevét, helyét és erőforráscsoportját. Válassza ki ugyanazt a helyet és erőforráscsoportot, mint a létrehozott IoT Hub. Ezután válassza a Véleményezés + létrehozás lehetőséget a fiók létrehozásához.

    Képernyőkép a Tárfiók létrehozása lapról az Azure Portalon.

  3. Miután létrehoztad a tárfiókodat, válaszd ki a Blob szolgáltatás csempét az Áttekintés panelen.

    Képernyőkép a Storage-fiók áttekintési oldalról, amelyen a Blob service van kiválasztva.

  4. A Blob szolgáltatás oldalán válassza a + Tároló lehetőséget az eszköztáron.

  5. Az Új tároló lapon adja meg a tároló nevét, például a container1 nevet. Hagyja magánjellegűként a nyilvános hozzáférési szintet(névtelen hozzáférés nélkül), és válassza a Létrehozás lehetőséget.

    Képernyőkép az Új tároló oldalról.

Stream Analytics-projekt létrehozása

Készíts egy Stream Analytics projektet a Visual Studio-ban, hogy meghatározd a munka bemeneteit, kimeneteit és lekérdezéseit.

  1. Indítsa el a Visual Studiót.

  2. Válassza a Fájl>Új projekt.

  3. A sablonlistában válaszd ki a Stream Analytics-et, majd az Azure Stream Analytics Application-t.

  4. Írd be a projekt nevét, helyszínét és megoldás nevét, majd válaszd a Létrehozást.

    Képernyőkép, amely a Create a Stream Analytics projekt párbeszédablakot mutatja.

  5. Figyeld meg az Azure Stream Analytics projekt elemeit.

    Képernyőkép a Visual Studióban egy Stream Analytics-mintaprojekt Megoldáskezelő ablakáról.

Válassza ki a szükséges előfizetést

Csatlakoztasd a Visual Studio-t az Azure előfizetéshez, amely tartalmazza az általad létrehozott erőforrásokat.

  1. A Visual Studióban a Nézet menüben válassza a Kiszolgálókezelő lehetőséget.
  2. Válassz és tartsd meg (vagy jobb kattintással) az Azure-t, válaszd a Microsoft Azure előfizetéshez való csatlakozást, majd jelentkezz be az Azure fiókoddal.

Bemenet definiálása

Állítsd be a feladat bemenetét úgy, hogy az az általad létrehozott IoT Hubból olvassa a streaming adatokat.

  1. Megoldáskezelő-ben bővítsd ki az Inputs csomópontot, és nyisd megInput.json.

  2. Töltse ki a Stream Analytics bemeneti konfigurációját a következő értékekkel:

    Setting Ajánlott érték Leírás
    Bemeneti alias Bemenet Írj be egy nevet, hogy azonosítsd a munka bemenetét.
    Forrás típusa Adatfolyam Válassza ki a megfelelő bemeneti forrást: adatfolyam vagy referenciaadatok.
    Forrás IoT Hub Válassza ki a megfelelő bemeneti forrást.
    Resource Adatforrás kiválasztása az aktuális fiókból Adja meg manuálisan az adatokat, vagy válasszon ki egy meglévő fiókot.
    Subscription <Az ön előfizetése> Válaszd ki azt az Azure előfizetést, amelyben az általad létrehozott IoT hub található.
    IoT Hub MyASAIoTHub Válassz vagy írj be az IoT hubod nevét. Az IoT hub nevek automatikusan jelennek meg, ha ugyanabban az előfizetésben hozod létre őket.

  3. A beállítások mentéséhez hagyja meg az egyéb beállításokat az alapértelmezett értékekre, és a Mentés gombra kattintva mentse a beállításokat.

    Képernyőkép a Stream Analytics bemeneti konfigurációs oldalról.

Kimenet definiálása

Konfiguráld be a munka kimenetét, hogy az eredményeket a blob tároló konténerbe írja le.

  1. Megoldáskezelő-ben bővítsd ki a Outputs csomópontot, és nyisd megOutput.json.

  2. Töltse ki a Stream Analytics kimeneti konfigurációját a következő értékekkel:

    Setting Ajánlott érték Leírás
    Kimeneti alias Kimenet Írj be egy nevet, hogy azonosítsd a munka kimenetét.
    Elsüllyed Data Lake Storage Gen 2/Blob Storage Válassza ki a megfelelő fogadót.
    Resource Adatforrás-beállítások manuális megadása Adja meg manuálisan az adatokat, vagy válasszon ki egy meglévő fiókot.
    Subscription <Az ön előfizetése> Válassza ki a létrehozott tárfiókot tartalmazó Azure-előfizetést. A tárfiók lehet ugyanabban vagy egy másik előfizetésben. Ez a példa feltételezi, hogy ugyanabban az előfizetésben hoztál létre egy tárolófiókot.
    Tárhelyfiók asaquickstartstorage Válassza ki vagy adja meg a tárfiók nevét. A tárolófiók nevek automatikusan megjelennek, ha ugyanabban az előfizetésben hozod létre őket.
    Konténer tároló1 Válassza ki a tárfiókban létrehozott meglévő tárolót.
    Útvonalminta kimenet Add meg a konténeren belül létrehozni kívánt fájl elérési útját.

  3. A beállítások mentéséhez hagyja meg az egyéb beállításokat az alapértelmezett értékekre, és a Mentés gombra kattintva mentse a beállításokat.

    Képernyőkép a Stream Analytics kimeneti konfigurációs oldalról.

A transzformációs lekérdezés definiálása

Definiálj egy lekérdezést, amely szűri az áramlási adatokat, és az eredményeket elküldi a kimenethez.

  1. Nyissa meg a Script.asaql parancsot a Visual Studióban a Megoldáskezelőben .

  2. Adja hozzá a következő lekérdezést:

    SELECT *
INTO Output
FROM Input
WHERE Temperature > 27

Stream Analytics-lekérdezés küldése az Azure-ba

Küldd be a lekérdezést az Azure-ba, hogy létrehozd a Stream Analytics feladatot.

  1. A Lekérdezésszerkesztőben válassza a Küldés az Azure-ba lehetőséget a szkriptszerkesztőben.

  2. A Feladat elküldése ablakban válassza az Új Azure Stream Analytics-feladat létrehozása lehetőséget.

  3. Adjon meg egy feladatnevet.

  4. Válassza ki az Azure-előfizetést.

  5. Válassza ki az erőforráscsoportot.

  6. Tartsa meg a Cluster alapértelmezett értékét.

  7. Válaszd ki azt a helyet , amit a gyorsindítás elején használtál.

  8. Válassza a Beküldés lehetőséget.

    Képernyőkép a Feladat elküldése párbeszédpanelről.

Az IoT-szimulátor futtatása

Futtasd a Raspberry Pi szimulátort, hogy mintaérzékelő adatokat küldj az IoT hubodhoz.

  1. Nyissa meg a Raspberry Pi Azure IoT Online szimulátort egy új böngészőlapon vagy ablakban.

  2. Cserélje le a helyőrzőt a 15. sorban az előző szakaszban mentett Azure IoT Hub eszközkapcsolati karakterláncra.

  3. Válassza a Futtatás parancsot. A kimenetnek meg kell mutatnia az IoT hubodhoz küldött szenzoradatokat és üzeneteket.

    Képernyőkép a Raspberry Pi Azure IoT Online szimulátorról.

Indítsa el a Stream Analytics-feladatot, és ellenőrizze a kimenetet

Indítsd el a munkát, és ellenőrizd, hogy feldolgozza a bemeneti eseményeket, és írja-e a kimenetet a blob tárolóba.

  1. Amikor létrehozod a munkádat, a munkakör nézete automatikusan megnyílik. Válaszd ki a zöld nyílgombot a munka elindításához.

    Képernyőkép egy Stream Analytics-feladat Visual Studióból való indításához a Start gombról.

  2. Módosítsa a feladat kimeneti kezdési módjátJobStartTime-ra , és válassza a Start lehetőséget.

    Képernyőkép a Stream Analytics Start Job Configuration párbeszédpanelről.

  3. A feladat állapota Futó értékre változik, és megjelennek a bemeneti és kimeneti események. Ez a változás néhány percet is igénybe vehet. Kattintson az eszköztár Frissítés gombjára a metrikák frissítéséhez.

    Képernyőkép a feladat futási állapotáról és a feladat metrikáiról.

  4. Az eredmények megtekintéséhez a Megtekintés menüben válaszd ki a Cloud Explorert, és menj a tárolófiókhoz az erőforrás-csoportodban. A Blob Containers alatt nyisd meg a container1-et, majd a kimeneti fájl útvonalát.

    A kimenetet bemutató képernyőkép a container1 blob konténer eredményét mutatja.

Erőforrások tisztítása

Ha már nincs rájuk szükséged, töröld az erőforráscsoportot, a streaming munkát és az összes kapcsolódó erőforrást. A feladat törlése megszünteti az általa használt streamingegységek utáni számlázást. Ha a jövőben használni tervezed a munkát, állítsd le, és később, amikor szükséged van rá, indítsd újra. Ha nem tervezed újra használni ezt a feladatot, az alábbi lépésekkel töröld az összes erőforrást, amit ez a gyorsindítás létrehozott:

  1. Az Azure portál bal oldali menüjéből válaszd ki az Erőforráscsoportokat, majd válaszd ki a létrehozott erőforrás nevét.
  2. Az erőforráscsoport lapján válassza a Törlés lehetőséget, írja be a törölni kívánt erőforrás nevét a szövegmezőbe, majd válassza a Törlés lehetőséget.

Kapcsolódó tartalom

  • Last updated on