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

Egyéni .NET-deszerializálók az Azure Stream Analyticshez a Visual Studióban (előzetes verzió)

  • Cikk

Fontos

Az Azure Stream Analytics egyéni .net deszerializálója 2024. szeptember 30-án megszűnik. A dátum után nem lehet majd használni a funkciót. Ezen a napon váltson JSON-, AVRO- vagy CSV-beépített deszerializálóra .

Az Azure Stream Analytics beépített támogatást nyújt három adatformátumhoz: JSON, CSV és Avro. Az egyéni .NET-deszerializálókkal adatokat olvashat más formátumokból, például a protokollpufferből, a Bondból és más felhasználó által definiált formátumokból a felhőbeli és az élfeladatokhoz.

Ez az oktatóanyag bemutatja, hogyan hozhat létre egyéni .NET-deszerializálót egy Azure Stream Analytics-felhőfeladathoz a Visual Studióval. A .NET-deszerializálók Visual Studio Code-ban való létrehozásáról a Visual Studio Code-ban az Azure Stream Analytics-feladatokhoz készült .NET-deszerializálók létrehozása című témakörben olvashat.

Ebben az oktatóanyagban az alábbiakkal fog megismerkedni:

  • Hozzon létre egy egyéni deszerializálót a protokollpufferhez.
  • Azure Stream Analytics-feladat létrehozása a Visual Studióban.
  • Konfigurálja a Stream Analytics-feladatot az egyéni deszerializáló használatára.
  • Futtassa helyileg a Stream Analytics-feladatot az egyéni deszerializáló teszteléséhez és hibakereséséhez.

Előfeltételek

Egyéni deszerializáló létrehozása

  1. Nyissa meg a Visual Studiót, és válassza az Új > projekt fájlja > lehetőséget. Keressen rá a Stream Analyticsre, és válassza az Azure Stream Analytics Custom Deserializer Project (.NET) lehetőséget. Adjon nevet a projektnek, például a Protobuf Deserializernek.

    Create Visual Studio dotnet standard class library project

  2. A Megoldáskezelő kattintson a jobb gombbal a Protobuf Deserializer-projektre, és válassza a NuGet-csomagok kezelése lehetőséget a menüből. Ezután telepítse a Microsoft.Azure.StreamAnalytics és a Google.Protobuf NuGet csomagokat.

  3. Adja hozzá a MessageBodyProto osztályt és a MessageBodyDeserializer osztályt a projekthez.

  4. Hozza létre a Protobuf Deserializer projektet.

Azure Stream Analytics-projekt hozzáadása

  1. A Megoldáskezelő kattintson a jobb gombbal a Protobuf Deserializer megoldásra, és válassza az Új projekt hozzáadása > lehetőséget. Az Azure Stream Analytics > Stream Analytics területén válassza az Azure Stream Analytics-alkalmazást. Nevezze el a ProtobufCloudDeserializer nevet, és válassza az OK gombot.

  2. Kattintson a jobb gombbal a Hivatkozások elemre a ProtobufCloudDeserializer Azure Stream Analytics-projekt alatt. A Projektek területen adja hozzá a Protobuf Deserializert. Automatikusan fel kell töltenie Önnek.

Stream Analytics-feladat konfigurálása

  1. Kattintson duplán a JobConfig.json. Használja az alapértelmezett konfigurációkat, kivéve a következő beállításokat:

    Beállítás Ajánlott érték
    Globális tárolási Gépház erőforrás Choose data source from current account (Adatforrás kiválasztása az aktuális fiókból)
    Globális tárolási Gépház-előfizetés < előfizetése >
    Globális tárfiók Gépház tárfiók < a tárfiók >
    Egyéni kódtár Gépház erőforrás Choose data source from current account (Adatforrás kiválasztása az aktuális fiókból)
    Egyéni kódtár Gépház tárfiók < a tárfiók >
    Egyéni kódtároló Gépház tároló < a tároló >

  2. A Bemenetek területen kattintson duplán a Input.json. Használja az alapértelmezett konfigurációkat, kivéve a következő beállításokat:

    Beállítás Ajánlott érték
    Forrás Blob Storage
    Erőforrás Choose data source from current account (Adatforrás kiválasztása az aktuális fiókból)
    Előfizetés < előfizetése >
    Tárfiók < a tárfiók >
    Tároló < a tároló >
    Eseményszerializációs formátum Egyéb (Protobuf, XML, védett...)
    Erőforrás Betöltés ASA-projektreferenciából vagy CodeBehindből
    CSharp-szerelvény neve ProtobufDeserializer.dll
    Osztály neve MessageBodyProto.MessageBodyDeserializer
    Esemény tömörítési típusa Egyik sem

  3. Adja hozzá a következő lekérdezést a Script.asaql fájlhoz.

    SELECT * FROM Input

  4. Töltse le a minta protobuf bemeneti fájlt. A Bemenetek mappában kattintson a jobb gombbal a Input.json, és válassza a Helyi bemenet hozzáadása lehetőséget. Ezután kattintson duplán a local_Input.json , és konfigurálja a következő beállításokat:

    Beállítás Ajánlott érték
    Input Alias (Bemeneti alias) Bevitel
    Source Type (Forrás típusa) Data Stream (Adatstream)
    Eseményszerializációs formátum Egyéb (Protobuf, XML, védett...)
    CSharp-szerelvény neve ProtobufDeserializer.dll
    Osztály neve MessageBodyProto.MessageBodyDeserializer
    Helyi bemeneti fájl elérési útja < a letöltött protobuf-minta bemeneti fájl elérési útja>

A Stream Analytics-feladat végrehajtása

  1. Nyissa meg a Script.asaql fájlt, és válassza a Helyi futtatás lehetőséget.

  2. Figyelje meg az eredményeket a Stream Analytics helyi futtatási eredményeiben.

Sikeresen implementált egy egyéni deszerializálót a Stream Analytics-feladathoz! Ebben az oktatóanyagban helyileg tesztelte az egyéni deszerializálót. A tényleges adatok esetében megfelelően konfigurálná a bemenetet és a kimenetet. Ezután küldje el a feladatot az Azure-nak a Visual Studióból, és futtassa a feladatot a felhőben az imént implementált egyéni deszerializáló használatával.

Hibakeresés a deszerializálóban

A .NET deszerializáló helyi hibakeresése ugyanúgy történik, mint a standard .NET-kód hibakeresése.

  1. Kattintson a jobb gombbal a ProtobufCloudDeserializer projekt nevére, és állítsa be indítási projektként.

  2. Adjon hozzá töréspontokat a függvényhez.

  3. Nyomja le az F5 billentyűt a hibakeresés megkezdéséhez. A program a várt módon leáll a töréspontoknál.

Az erőforrások eltávolítása

Ha már nincs szükség rá, törölheti az erőforráscsoportot, a folyamatos átviteli feladatot és az összes kapcsolódó erőforrást. A feladat törlésével megakadályozhatja, hogy a feladat által felhasznált streamelési egységek kiszámlázásra kerüljenek. Ha a feladatot a jövőben is szeretné használni, leállíthatja, és később újraindíthatja amikor ismét szükség van rá. Ha már nem használja a feladatot, akkor a következő lépésekkel az oktatóanyagban létrehozott összes erőforrást törölheti:

  1. Az Azure Portal bal oldali menüjében válassza az Erőforráscsoportok menüpontot, majd válassza ki a létrehozott erőforrás nevét.

  2. Az erőforráscsoport lapján válassza a Törlés elemet, í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.

Következő lépések

Ebben az oktatóanyagban megtanulta, hogyan implementálhat egy egyéni .NET-deszerializálót a protokollpuffer bemeneti szerializálásához. Ha többet szeretne megtudni az egyéni deszerializálók létrehozásáról, folytassa a következő cikkel:

Különböző .NET-deszerializálók létrehozása az Azure Stream Analytics-feladatokhoz