Azure Stream Analytics di IoT Edge

Azure Stream Analytics di IoT Edge adalah versi ringan Azure Stream Analytics yang berjalan langsung di perangkat IoT Edge untuk analitik mendekati real-time pada data yang dihasilkan perangkat. Azure Stream Analytics pada IoT Edge memberikan latensi rendah, ketahanan, penggunaan bandwidth yang efisien, dan kepatuhan terhadap peraturan. Anda dapat menyebarkan analitik dan mengontrol logika yang dekat dengan operasi industri saat menggunakan Azure Stream Analytics berbasis cloud untuk pemrosesan data skala besar.

Azure Stream Analytics di IoT Edge berjalan dalam kerangka kerja Azure IoT Edge . Setelah membuat pekerjaan Azure Stream Analytics di portal Azure, Anda dapat menyebarkan dan mengelolanya dengan menggunakan IoT Hub.

Skenario umum untuk Azure Stream Analytics di IoT Edge

Diagram berikut menunjukkan aliran data antara perangkat IoT dan cloud Azure.

Diagram yang menunjukkan aliran data antara perangkat IoT dan cloud Azure.

Perintah dan kontrol latensi rendah

Sistem keselamatan manufaktur harus merespons data operasional dengan latensi ultra rendah. Dengan menggunakan Stream Analytics di IoT Edge, Anda dapat menganalisis data sensor mendekati real-time, dan mengeluarkan perintah saat Mendeteksi anomali untuk menghentikan komputer atau memicu pemberitahuan.

Konektivitas terbatas ke cloud

Sistem misi penting, seperti peralatan penambangan jarak jauh, kapal yang terhubung, atau pengeboran lepas pantai, perlu menganalisis dan bereaksi terhadap data bahkan ketika konektivitas cloud terputus-putus. Dengan menggunakan Stream Analytics, logika streaming Anda berjalan secara independen dari konektivitas jaringan dan Anda dapat memilih apa yang Anda kirim ke cloud untuk pemrosesan atau penyimpanan lebih lanjut.

Bandwidth terbatas

Volume data yang dihasilkan oleh mesin jet atau mobil yang terhubung bisa sangat besar sehingga Anda harus memfilter atau memprosesnya sebelum mengirimkannya ke cloud. Dengan menggunakan Azure Stream Analytics, Anda dapat memfilter atau mengagregasi data yang perlu Anda kirim ke cloud.

Kepatuhan terhadap peraturan dan pemrosesan data lokal

Kepatuhan terhadap peraturan mungkin mengharuskan Anda untuk menganonimkan atau menggabungkan beberapa data secara lokal sebelum Anda mengirimkannya ke cloud. Dengan menggunakan Azure Stream Analytics di IoT Edge, Anda dapat memproses data sensitif lokal dan hanya mengirim hasil yang sesuai dan diubah ke cloud.

Pekerjaan Edge di Azure Stream Analytics

Job edge Stream Analytics adalah beban kerja Stream Analytics yang dikontainerkan dan diterapkan ke perangkat Azure IoT Edge. Pekerjaan Edge memiliki dua bagian:

  • Bagian cloud yang menangani definisi pekerjaan: Anda menentukan input, output, kueri, dan pengaturan lainnya, seperti peristiwa yang tidak berurutan, di cloud.

  • Modul yang berjalan di perangkat IoT Anda. Modul berisi mesin Azure Stream Analytics dan menerima definisi pekerjaan dari cloud.

Azure Stream Analytics menggunakan IoT Hub untuk menyebarkan pekerjaan edge ke perangkat. Untuk informasi selengkapnya, lihat Penyebaran IoT Edge.

Diagram yang memperlihatkan komponen Azure Stream Analytics edge job.

Batasan pekerjaan Edge

Job edge Azure Stream Analytics ditujukan agar setara antara penerapan di edge dan di cloud. Pekerjaan cloud adalah pekerjaan Azure Stream Analytics standar yang berjalan di Azure, sementara pekerjaan edge berjalan secara lokal pada perangkat IoT Edge. Stream Analytics mendukung sebagian besar fitur bahasa kueri SQL baik di edge maupun di cloud. Namun, job edge tidak mendukung fitur berikut:

  • Fungsi yang ditentukan pengguna (UDF) di JavaScript. UDF tersedia di C# untuk pekerjaan IoT Edge (pratinjau).
  • Agregat yang ditentukan pengguna (UDA).
  • fungsi Azure Machine Learning
  • Format AVRO untuk input/output. Pekerjaan Edge hanya mendukung format CSV dan JSON.
  • Operator SQL berikut:
    • PARTITION BY
    • GetMetadataPropertyValue
  • Kebijakan kedatangan terlambat

Persyaratan runtime dan perangkat keras

Untuk menjalankan Stream Analytics di IoT Edge, Anda memerlukan perangkat yang menjalankan Azure IoT Edge.

Stream Analytics dan Azure IoT Edge menggunakan kontainer Docker untuk menyediakan solusi portabel yang berjalan pada beberapa sistem operasi host (Windows, Linux).

Stream Analytics di IoT Edge berjalan sebagai citra Linux pada arsitektur x86-64 dan ARM.

Masukan dan keluaran untuk job edge Stream Analytics

Pekerjaan edge Azure Stream Analytics mendapatkan input dan output dari modul lain yang berjalan di perangkat IoT Edge. Untuk menghubungkan ke dan dari modul tertentu, atur konfigurasi perutean saat penerapan. Untuk informasi selengkapnya, lihat dokumen komposisi modul IoT Edge.

Input dan output mendukung format CSV dan JSON.

Untuk setiap aliran input dan output yang Anda buat dalam pekerjaan Stream Analytics Anda, Stream Analytics membuat titik akhir yang sesuai pada modul yang diterapkan. Gunakan titik akhir ini dalam rute penyebaran Anda.

Jenis input aliran yang didukung adalah:

  • Edge Hub
  • Pusat Aktivitas
  • IoT Hub

Jenis output aliran yang didukung adalah:

  • Edge Hub
  • SQL Database
  • Pusat Aktivitas
  • Blob Storage/Azure Data Lake Storage Gen2

Input referensi mendukung jenis file referensi, yang menyediakan data statis atau berubah lambat untuk pencarian. Untuk mencapai tujuan output lainnya, hubungkan pekerjaan Stream Analytics yang dihosting di cloud sebagai downstream. Misalnya, pekerjaan Azure Stream Analytics yang dihosting di IoT Edge mengirim output ke Edge Hub, yang kemudian dapat mengirim output ke IoT Hub. Gunakan job Azure Stream Analytics kedua yang dihosting di cloud dengan masukan dari IoT Hub dan keluaran ke Power BI atau jenis keluaran lainnya.

Informasi gambar modul Azure Stream Analytics

Tabel berikut mencantumkan image modul Stream Analytics on IoT Edge yang tersedia. Informasi versi ini terakhir diperbarui pada 2020-09-21. Periksa Microsoft Container Registry untuk versi terbaru yang tersedia.

Gambar Gambar dasar 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 lengan 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

Gambar dasar yang tercantum dalam tabel ini menggunakan .NET Core 2.1 dan 3.0, yang telah mencapai akhir masa pakai. Periksa Microsoft Container Registry untuk Analisis Aliran yang diperbarui pada gambar IoT Edge yang dibangun pada versi .NET yang didukung.