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

Azure Stream Analytics-erőforrásmodell

Az Azure Stream Analytics egy teljes körűen felügyelt, szolgáltatásként nyújtott platform (PaaS) a streamfeldolgozáshoz. Ez a cikk a Stream Analytics erőforrásmodelljét ismerteti a Stream Analytics-fürt, a feladat és a feladat összetevőinek bevezetésével.

Stream Analytics-feladat

A Stream Analytics-feladat a Stream Analytics alapvető egysége, amely lehetővé teszi a streamfeldolgozási logika meghatározását és futtatását. A feladatok 3 fő összetevőből állnak:

  • Bevitel
  • Hozam
  • Lekérdezés

Bevitel

Egy feladat egy vagy több bemenettel rendelkezhet az adatok folyamatos olvasásához. Ezek a streamelési bemeneti adatforrások lehetnek Azure Event Hubs, Azure IoT Hub vagy Azure Storage. A Stream Analytics emellett támogatja a statikus vagy lassú változó bemeneti adatok (úgynevezett referenciaadatok) olvasását is, amelyeket gyakran használnak a streamelési adatok bővítésére. A bemenetek hozzáadása a feladathoz nulla kódú művelet.

Hozam

A feladatok egy vagy több kimenettel is rendelkezhetnek az adatok folyamatos írásához. A Stream Analytics 12 különböző kimeneti fogadót támogat, köztük az Azure SQL Database-t, az Azure Data Lake Storage-t, az Azure Cosmos DB-t, a Power BI-t stb. A kimenetek hozzáadása a feladathoz szintén nulla kódú művelet.

Lekérdezés

A streamfeldolgozási logikát úgy valósíthatja meg, hogy egy SQL-lekérdezést ír a feladatba. A gazdag SQL-nyelvi támogatás lehetővé teszi olyan forgatókönyvek kezelését, mint az összetett JSON elemzése, az értékek szűrése, a számítási aggregátumok, az illesztések végrehajtása és még fejlettebb használati esetek, például a térinformatikai elemzés és az anomáliadetektálás. Ezt az SQL-nyelvet a JavaScript felhasználó által definiált függvényekkel (UDF) és a felhasználó által definiált összesítésekkel (UDA) is bővítheti. A Stream Analytics lehetővé teszi a feladat beállításaiban szereplő egyszerű konfigurációkon keresztül a késői és a rendelésen kívüli események egyszerű beállítását is. Dönthet úgy is, hogy a lekérdezést a bemeneti esemény bemeneti forráshoz érkezési ideje vagy az esemény forrásánál létrejött esemény alapján hajtja végre.

Feladat futtatása

Miután kifejlesztette a feladatot bemenetek, kimenetek és lekérdezések konfigurálásával, elindíthatja a feladatot a streamelési egységek számának megadásával. Miután a feladat elindult, futó állapotba kerül, és ebben az állapotban marad, amíg explicit módon le nem áll, vagy helyreállíthatatlan hibába nem ütközik. Ha a feladat futó állapotban van, folyamatosan lekéri az adatokat a bemeneti forrásokból, végrehajtja a lekérdezési logikát, amely ezredmásodpercnyi végpontok közötti késéssel hozza létre a kimeneti fogadókba írt eredményeket.

A feladat elindításakor a Stream Analytics szolgáltatás gondoskodik a lekérdezés összeállításáról, és a feladatban konfigurált streamegységek száma alapján hozzárendel bizonyos mennyiségű számítási és memóriamennyiséget. Nem kell aggódnia semmilyen mögöttes infrastruktúra miatt fürtkarbantartás, biztonsági javítások miatt, mivel a platform automatikusan gondoskodik róla. Ha a standard termékváltozatban futtat feladatokat, a streamelési egységekért csak a feladat futtatásakor kell fizetnie.

Stream Analytics-fürt

Alapértelmezés szerint a Stream Analytics-feladatok a Standard termékváltozatot létrehozó több-bérlős Standard környezetben futnak. A Stream Analytics dedikált termékváltozatot is biztosít, ahol kiépítheti az Önhöz tartozó teljes Stream Analytics-fürtöt. Ezzel teljes mértékben szabályozhatja, hogy mely feladatok futnak a fürtön. A Stream Analytics-fürtök minimális mérete 12 streamelési egység, és a teljes fürtkapacitásért a kiépítéskor kell fizetnie. További információ a Stream Analytics-fürtök előnyeiről és használatuk időpontjáról.

Diagram that shows Standard multi-tenant environment in Stream Analytics.

Diagram that shows Dedicated environment in Stream Analytics.

Következő lépések

Ismerje meg, hogyan kezelheti az Azure Stream Analyticst és más fogalmakat:

  • Last updated on