IoT Edge-eszközökön futó Azure Stream Analytics

A IoT Edge Azure Stream Analytics a Azure Stream Analytics egyszerűsített verziója, amely közvetlenül IoT Edge eszközökön fut az eszköz által létrehozott adatok közel valós idejű elemzéséhez. Azure Stream Analytics IoT Edge alacsony késést, rugalmasságot, a sávszélesség hatékony használatát és jogszabályi megfelelőséget biztosít. Az elemzési és vezérlési logikát az ipari műveletekhez közel helyezheti üzembe, miközben felhőalapú Azure Stream Analytics használ a nagy léptékű adatfeldolgozáshoz.

Az Azure Stream Analytics az IoT Edge-en az Azure IoT Edge-keretrendszeren belül fut. Miután létrehozott egy Stream Analytics-feladatot a Azure portálon, üzembe helyezheti és kezelheti azt a IoT Hub használatával.

Az IoT Edge-hez készült Stream Analytics gyakori forgatókönyvei

Az alábbi ábra az IoT-eszközök és az Azure-felhő közötti adatáramlást mutatja be.

Az IoT-eszközök és az Azure-felhő közötti adatáramlást bemutató diagram.

Kis késésű parancs és vezérlés

A gyártási biztonsági rendszereknek rendkívül alacsony késéssel kell válaszolniuk a működési adatokra. A Stream Analytics IoT Edge használatával közel valós időben elemezheti az érzékelőadatokat, és parancsokat adhat ki, amikor rendellenességeket észlel a gépek leállításához vagy riasztások aktiválásához.

Korlátozott kapcsolat a felhőhöz

A kritikus fontosságú rendszereknek, például a távoli bányászati berendezéseknek, a csatlakoztatott hajóknak vagy a tengeri fúrásoknak akkor is elemezni és reagálni kell az adatokra, ha a felhőkapcsolat időszakos. A Stream Analytics használatával a streamelési logika a hálózati kapcsolattól függetlenül fut, és kiválaszthatja, hogy mit küld a felhőbe további feldolgozás vagy tárolás céljából.

Korlátozott sávszélesség

A sugárhajtású motorok vagy a csatlakoztatott autók által előállított adatok mennyisége olyan nagy lehet, hogy a felhőbe való küldés előtt szűrnie vagy elő kell feldolgoznia azokat. A Stream Analytics használatával szűrheti vagy összesítheti a felhőbe küldendő adatokat.

Jogszabályi megfelelőség és helyi adatfeldolgozás

A jogszabályi megfelelőség megkövetelheti, hogy helyileg anonimizáljon vagy összesítsen néhány adatot, mielőtt elküldené őket a felhőbe. A Stream Analytics IoT Edge használatával feldolgozhatja a helyszíni bizalmas adatokat, és csak megfelelő, átalakított eredményeket küldhet a felhőbe.

Edge-feladatok az Azure Stream Analyticsben

A Stream Analytics peremhálózati feladatai tárolóalapú Stream Analytics-számítási feladatok, amelyeket Azure IoT Edge eszközökre helyeznek üzembe. Az Edge-feladatok két részből állnak:

  • A feladatdefiníciót kezelő felhőrész: a felhőben bemeneteket, kimeneteket, lekérdezéseket és egyéb beállításokat, például rendelésen kívüli eseményeket definiálhat.

  • Az IoT-eszközökön futó modul. A modul tartalmazza a Stream Analytics motort, és megkapja a feladatdefiníciót a felhőből.

A Stream Analytics IoT Hub használ a peremhálózati feladatok eszközökre való üzembe helyezéséhez. További információkért lásd az IoT Edge üzembe helyezését.

Diagram, amely egy Azure Stream Analytics élfeladat összetevőit jeleníti meg.

Peremhálózati feladatok korlátozásai

A Stream Analytics peremhálózati feladatai arra törekszenek, hogy a peremhálózati és a felhőbeli üzembe helyezések egységesek legyenek. A felhőfeladat egy szabványos Azure Stream Analytics feladat, amely Azure fut, míg az élfeladatok helyileg futnak egy IoT Edge eszközön. A Stream Analytics a legtöbb SQL-lekérdezési nyelvi funkciót támogatja a peremhálózaton és a felhőben is. Az élfeladatok azonban nem támogatják a következő funkciókat:

  • Felhasználó által definiált függvények (UDF) a JavaScriptben. Az UDF-ek C# nyelven érhetők el IoT Edge feladatokhoz (előzetes verzió).
  • Felhasználó által definiált összesítések (UDA).
  • Azure Machine Learning függvények.
  • AVRO formátum bemenethez/kimenethez. Az Edge-feladatok csak CSV- és JSON-formátumokat támogatnak.
  • A következő SQL-operátorok:
    • PARTITION BY
    • GetMetadataPropertyValue
  • Késői érkezési szabályzat

Futtatókörnyezetre és hardverre vonatkozó követelmények

A Stream Analytics IoT Edge való futtatásához Azure IoT Edge futtató eszközökre van szükség.

A Stream Analytics és az Azure IoT Edge Docker-tárolókkal biztosít egy hordozható megoldást, amely több gazda operációs rendszeren (Windows, Linux) fut.

A Stream Analytics az IoT Edge linuxos rendszerképként fut x86-64-es és ARM-architektúrákon.

Bemenetek és kimenetek a Stream Analytics peremhálózati feladataihoz

A Stream Analytics peremhálózati feladatai bemeneteket és kimeneteket kapnak más, IoT Edge eszközökön futó moduloktól. Ha adott modulokból és modulokhoz szeretne csatlakozni, állítsa be az útválasztási konfigurációt az üzembe helyezéskor. További információ: az IoT Edge modulösszeállítás dokumentációja.

A bemenetek és a kimenetek egyaránt támogatják a CSV- és JSON-formátumokat.

A Stream Analytics-feladatban létrehozott minden egyes bemeneti és kimeneti streamhez a Stream Analytics létrehoz egy megfelelő végpontot az üzembe helyezett modulon. Használja ezeket a végpontokat az üzembe helyezés útvonalán.

A támogatott streambemenet-típusok a következők:

  • Edge Hub
  • Eseményközpont
  • IoT Hub

A támogatott streamkimenet-típusok a következők:

  • Edge Hub
  • SQL adatbázis
  • Eseményközpont
  • Blob Storage/Azure Data Lake Storage Gen2

A referenciabemenet támogatja a referenciafájl típusát, amely statikus vagy lassan változó adatokat biztosít a keresésekhez. Ha más kimeneti célhelyeket szeretne elérni, láncba kell láncelnie egy felhőben üzemeltetett Stream Analytics-feladatot az alsóbb rétegben. Például az IoT Edge-en futó Stream Analytics-feladat kimenetet küld az Edge Hubnak, amely ezt követően továbbíthatja azt az IoT Hubnak. Használjon egy második, felhőben üzemeltetett Azure Stream Analytics-feladatot, amelynek bemenete az IoT Hubból származik, a kimenete pedig a Power BI-ba vagy egy másik kimeneti típusba irányul.

Az Azure Stream Analytics modul képadatai

Az alábbi táblázat IoT Edge modulképeken elérhető Stream Analytics-adatokat sorolja fel. Ez a verzióinformáció legutóbb 2020.09.21-én frissült. A legújabb elérhető verziókért tekintse meg a Microsoft tárolóregisztrációs adatbázist.

Image Alapkép Architecture OS
mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-amd64 mcr.microsoft.com/dotnet/core/runtime:2.1.13-alpine amd64 Linux
mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-arm32v7 mcr.microsoft.com/dotnet/core/runtime:2.1.13-bionic-arm32v7 kar Linux
mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-arm64 mcr.microsoft.com/dotnet/core/runtime:3.0-bionic-arm64v8 arm64 Linux

Important

A táblázatban felsorolt alapképek .NET Core 2.1 és 3.0-s verzióját használják, amelyek az élettartam végéhez értek. Ellenőrizze a Microsoft Container Registry-ben a támogatott .NET-verziókra épülő, frissített Stream Analytics on IoT Edge rendszerképeket.