Azure Stream Analytics di IoT Edge

  • Artikel

Azure Stream Analytics di IoT Edge memberdayakan pengembang untuk menyebarkan kecerdasan analitik mendekati real-time lebih dekat dengan perangkat IoT agar dapat membuka nilai utuh dari data yang dihasilkan perangkat. Azure Stream Analytics dirancang untuk latensi rendah, ketahanan, penggunaan bandwidth yang efisien, dan kepatuhan. Perusahaan dapat menyebarkan logika kontrol yang mendekati operasi industri dan melengkapi analitik Big Data yang dijalankan di cloud.

Azure Stream Analytics di IoT Edge dijalankan di dalam kerangka kerja Azure IoT Edge. Setelah tugas dibuat di Azure Stream Analytics, Anda dapat menyebarkan dan mengelolanya menggunakan IoT Hub.

Skenario umum

Bagian ini menjelaskan skenario umum untuk Azure Stream Analytics di IoT Edge. Diagram berikut menampilkan aliran data antara perangkat IoT dan cloud Azure.

High level diagram of IoT Edge

Perintah dan kontrol latensi rendah

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

Konektivitas terbatas ke cloud

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

Bandwidth terbatas

Volume data yang dihasilkan oleh mesin jet atau mobil yang terhubung kemungkinan sangat besar sehingga data harus difilter atau diproses terlebih dahulu sebelum dikirimkan ke cloud. Dengan Azure Stream Analytics, Anda dapat memfilter atau mengagregasi data yang perlu dikirim ke cloud.

Kepatuhan

Kepatuhan terhadap peraturan mungkin mengharuskan beberapa data dianonimkan atau diagregatkan secara lokal sebelum dikirim ke cloud.

Pekerjaan edge di Azure Stream Analytics

Pekerjaan Stream Analytics Edge dijalankan dalam kontainer yang disebarkan ke perangkat Azure IoT Edge. Pekerjaan edge terdiri dari dua bagian:

  • Bagian cloud yang bertanggung jawab atas definisi kerja: pengguna menentukan input, output, kueri, dan pengaturan lainnya, seperti peristiwa yang tidak sesuai urutan, di cloud.

  • Modul yang berjalan pada perangkat IoT Anda. Modul ini berisi mesin Azure Stream Analytics dan menerima definisi kerja dari cloud.

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

Azure Stream Analytics Edge job

Batasan pekerjaan edge

Tujuannya adalah untuk memiliki keseimbangan antara pekerjaan IoT Edge dan pekerjaan cloud. Sebagian besar fitur bahasa kueri SQL didukung untuk edge dan awan. Namun, fitur berikut ini tidak didukung untuk pekerjaan edge:

  • Fungsi yang ditentukan pengguna (UDF) dalam JavaScript. UDF tersedia dalam C# untuk pekerjaan IoT Edge (pratinjau).
  • Agregat yang ditentukan pengguna (UDA).
  • Fungsi Azure ML.
  • Format AVRO untuk input/output. Saat ini, hanya CSV dan JSON yang didukung.
  • Operator SQL berikut:
    • PARTISI BERDASARKAN
    • GetMetadataPropertyValue
  • Kebijakan keterlambatan kedatangan

Persyaratan runtime dan perangkat keras

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

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

Azure Stream Analytics di IoT Edge tersedia dalam citra Windows dan Linux, yang berjalan pada arsitektur x86-64 atau ARM (Advanced RISC Machines).

Input dan output

Pekerjaan Stream Analytics Edge bisa mendapatkan input dan output dari modul lainnya yang berjalan di perangkat IoT Edge. Untuk menyambungkan dari dan ke modul tertentu, Anda dapat mengatur konfigurasi perutean pada waktu penyebaran. Informasi lebih lanjut dijelaskan pada dokumentasi komposisi modul IoT Edge.

Untuk input dan output, format CSV dan JSON didukung.

Untuk setiap aliran input dan output yang Anda buat di pekerjaan Azure Stream Analytics, titik akhir terkait dibuat pada modul yang disebarkan. Titik akhir ini dapat digunakan pada rute penyebaran Anda.

Jenis input aliran yang didukung adalah:

  • Edge Hub
  • Pusat Aktivitas
  • IoT Hub

Jenis output stream yang didukung adalah:

  • Edge Hub
  • SQL Database
  • Pusat Aktivitas
  • Blob Storage/ADLS Gen2

Input referensi mendukung jenis file referensi. Output lain dapat dicapai menggunakan pekerjaan cloud di hilir. Contohnya, pekerjaan Azure Stream Analytics yang dihosting di Edge mengirimkan output ke Edge Hub, yang kemudian dapat mengirim output ke IoT Hub. Anda dapat menggunakan pekerjaan Azure Stream Analytics kedua yang dihosting cloud dengan input dari IoT Hub dan output ke Power BI atau jenis output lainnya.

Lisensi dan pemberitahuan pihak ketiga

Informasi gambar modul Azure Stream Analytics

Informasi versi ini terakhir diperbarui pada 2020-09-21:

  • Gambar: mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-amd64

    • gambar dasar: mcr.microsoft.com/dotnet/core/runtime:2.1.13-alpine
    • Platform:
      • arsitektur: amd64
      • os: linux

  • Gambar: mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-arm32v7

    • gambar dasar: mcr.microsoft.com/dotnet/core/runtime:2.1.13-bionic-arm32v7
    • Platform:
      • arsitektur: arm
      • os: linux

  • Gambar: mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-arm64

    • gambar dasar: mcr.microsoft.com/dotnet/core/runtime:3.0-bionic-arm64v8
    • Platform:
      • arsitektur: arm64
      • os: linux

Dapatkan bantuan

Untuk bantuan lebih lanjut, coba lihat Halaman pertanyaan Q&A Microsoft untuk Azure Stream Analytics.

Langkah berikutnya