Azure Stream Analytics na IoT Edge

Azure Stream Analytics na IoT Edge je zjednodušená verze Azure Stream Analytics, která běží přímo na zařízeních IoT Edge pro analýzu dat generovaných zařízením téměř v reálném čase. Azure Stream Analytics na IoT Edge poskytuje nízkou latenci, odolnost, efektivní využití šířky pásma a dodržování právních předpisů. Logiku analýzy a řízení můžete nasadit blízko průmyslových operací při používání cloudových Azure Stream Analytics pro zpracování velkých objemů dat.

Azure Stream Analytics ve službě IoT Edge běží v rámci architektury Azure IoT Edge . Po vytvoření úlohy Stream Analytics na portálu Azure ji můžete nasadit a spravovat pomocí IoT Hub.

Běžné scénáře pro Stream Analytics na IoT Edge

Následující diagram znázorňuje tok dat mezi zařízeními IoT a cloudem Azure.

Diagram znázorňující tok dat mezi zařízeními IoT a Azure cloud.

Příkaz a řízení s nízkou latencí

Systémy bezpečnosti výroby musí reagovat na provozní data s ultra nízkou latencí. Pomocí Stream Analytics na IoT Edge můžete analyzovat data senzorů téměř v reálném čase a vydávat příkazy, když zjistíte anomálie, které zastaví počítač nebo aktivují výstrahy.

Omezené připojení ke cloudu

Důležité systémy, jako jsou zařízení pro vzdálené dolování, připojené plavidla nebo pobřežní vrtáky, potřebují analyzovat data a reagovat na ně, i když je připojení ke cloudu přerušované. Pomocí Stream Analytics běží logika streamování nezávisle na síťovém připojení a můžete zvolit, co odesíláte do cloudu pro další zpracování nebo úložiště.

Omezená šířka pásma

Objem dat vytvořených motory jetů nebo připojených aut může být tak velký, že je musíte před odesláním do cloudu filtrovat nebo předem zpracovat. Pomocí Stream Analytics můžete filtrovat nebo agregovat data, která potřebujete odeslat do cloudu.

Dodržování právních předpisů a místní zpracování dat

Dodržování právních předpisů může vyžadovat, abyste před odesláním do cloudu místně anonymizovali nebo agregovali některá data. Pomocí Stream Analytics na IoT Edge můžete zpracovávat citlivá data místně a odesílat do cloudu pouze vyhovující a transformované výsledky.

Úlohy Edge ve službě Azure Stream Analytics

Úlohy Stream Analytics edge jsou kontejnerizované úlohy Stream Analytics nasazené do Azure IoT Edge zařízení. Úlohy Edge mají dvě části:

  • Cloudová část, která zpracovává definici úlohy: definujete vstupy, výstup, dotaz a další nastavení, jako jsou události mimo pořadí, v cloudu.

  • Modul spuštěný na vašich zařízeních IoT. Modul obsahuje modul Stream Analytics a přijímá definici úlohy z cloudu.

Stream Analytics používá IoT Hub k nasazení úloh edge na zařízení. Další informace najdete v tématu Nasazení IoT Edge.

Diagram, který zobrazuje komponenty úlohy Azure Stream Analytics edge job.

Omezení úloh Edge

Úlohy Stream Analytics edge cílí na paritu mezi hraničními a cloudovými nasazeními. Cloudová úloha je standardní úloha služby Azure Stream Analytics, která běží v Azure, zatímco okrajová úloha se spouští místně na zařízení IoT Edge. Stream Analytics podporuje většinu funkcí dotazovacího jazyka SQL pro edge i cloud. Úlohy Edge ale nepodporují následující funkce:

  • Uživatelem definované funkce (UDF) v JavaScriptu Uživatelsky definované funkce jsou k dispozici v C# pro úlohy IoT Edge (verze Preview).
  • Uživatelem definované agregace (UDA).
  • Funkce služby Azure Machine Learning.
  • Formát AVRO pro vstup/výstup Úlohy Edge podporují jenom formáty CSV a JSON.
  • Následující operátory SQL:
    • PARTITION BY
    • GetMetadataPropertyValue
  • Zásady pozdního příjezdu

Požadavky na runtime a hardware

Pokud chcete spustit Stream Analytics na IoT Edge, potřebujete zařízení, na kterých běží Azure IoT Edge.

Stream Analytics a Azure IoT Edge používají kontejnery Dockeru k zajištění přenosného řešení, které běží na několika hostitelských operačních systémech (Windows, Linux).

Stream Analytics on IoT Edge běží jako linuxové image na architekturách x86-64 a ARM.

Vstupy a výstupy pro hraniční úlohy Stream Analytics

Úlohy Stream Analytics edge získávají vstupy a výstupy z jiných modulů spuštěných na IoT Edge zařízeních. Chcete-li se připojovat z konkrétních modulů a ke konkrétním modulům, nastavte konfiguraci směrování při nasazení. Další informace najdete v dokumentaci ke složení modulu IoT Edge.

Vstupy i výstupy podporují formáty CSV a JSON.

Pro každý vstupní a výstupní datový proud, který vytvoříte v úloze Stream Analytics, vytvoří Stream Analytics odpovídající koncový bod v nasazeném modulu. Tyto koncové body použijte v trasách nasazení.

Podporované vstupní typy datových proudů jsou:

  • Edge Hub
  • Centrum událostí
  • Centrum IoT

Podporované typy výstupu streamu jsou:

  • Edge Hub
  • Databáze SQL
  • Centrum událostí
  • Blob Storage/Azure Data Lake Storage Gen2

Odkazový vstup podporuje typ referenčního souboru, který poskytuje statická nebo pomalu se měnící data pro vyhledávání. Pokud chcete dosáhnout jiných výstupních cílů, zřetězte úlohu Stream Analytics hostované v cloudu. Například úloha Stream Analytics hostovaná na IoT Edge odesílá výstup do Edge Hubu, který pak může odesílat výstup do IoT Hub. Použijte druhou úlohu hostované v cloudu Azure Stream Analytics se vstupem z IoT Hub a výstupem pro Power BI nebo jiný typ výstupu.

Informace o imagi modulu Azure Stream Analytics

Následující tabulka uvádí dostupné image modulu Stream Analytics pro IoT Edge. Tyto informace o verzi byly naposledy aktualizovány 2020-09-21. Nejnovější dostupné verze najdete v Microsoft Container Registry.

Obrázek Základní obraz 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 paže 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

Základní image uvedené v této tabulce používají .NET Core 2.1 a 3.0, které dosáhly konce životnosti. Podívejte se do Microsoft Container Registry na aktualizované bitové kopie Stream Analytics on IoT Edge sestavené na podporovaných verzích .NET.