Pemrosesan pesan dalam solusi IoT

Gambaran umum ini memperkenalkan konsep utama sekeliling pemrosesan pesan yang dikirim dari aset dan perangkat Anda dalam solusi Azure IoT yang khas. Setiap bagian menyertakan tautan ke konten yang memberikan detail dan panduan lebih lanjut.

Solusi berbasis Edge

Diagram berikut menunjukkan tampilan tingkat tinggi komponen dalam solusi IoT berbasis tepi yang khas. Artikel ini berfokus pada komponen pemrosesan pesan dari solusi IoT berbasis tepi.

Solusi berbasis cloud

Diagram berikut menunjukkan tampilan tingkat tinggi komponen dalam solusi IoT berbasis cloud yang khas. Artikel ini berfokus pada komponen pemrosesan pesan dari solusi IoT berbasis cloud.

In Azure IoT, message processing refers to processes such as routing and enriching messages sent by assets and devices. Proses ini digunakan untuk mengontrol alur pesan melalui solusi IoT dan untuk menambahkan informasi tambahan ke pesan.

Route messages

Solusi berbasis Edge

Untuk merutekan pesan dari aset Anda ke berbagai titik akhir, Azure IoT Operations menggunakan aliran data . Titik akhir tujuan mungkin berada di awan atau di tepi. Daftar titik akhir tujuan yang tersedia meliputi:

Jenis titik akhir	Deskripsi
MQTT	Untuk olahpesan dua arah dengan broker MQTT, termasuk yang bawaan ke Azure IoT Operations dan Event Grid.
Kafka	Untuk pesan dua arah dengan broker Kafka, termasuk Azure Event Hubs.
Data Lake	Untuk mengunggah data ke akun penyimpanan Azure Data Lake Gen2.
Microsoft Fabric OneLake	Untuk mengunggah data ke rumah danau Microsoft Fabric OneLake.
Azure Data Explorer	Untuk mengunggah data ke database Azure Data Explorer.
Penyimpanan lokal	Untuk mengirim data ke volume persisten yang tersedia secara lokal, secara opsional dapat dikonfigurasi dengan Azure Container Storage yang diaktifkan oleh Azure Arc.

Antarmuka pengguna web pengalaman operasi menyediakan lingkungan tanpa kode untuk membangun dan menjalankan aliran data Anda.

For enhanced security in the data that is routed to your endpoints, cloud/edge synchronized secrets are used in data flow endpoints for authentication.

While data flows let you configure routing at the edge, you can also define routing in the cloud. Jika aliran data Anda mengirimkan pesan ke Azure Event Grid, Anda dapat menggunakan fitur routing-nya untuk menentukan tempat mengirim pesan.

Untuk mempelajari lebih lanjut, lihat Memproses dan merutekan data dengan aliran data.

Solusi berbasis cloud

Hub Azure IoT menyediakan titik masuk cloud untuk pesan telemetri yang dikirim perangkat Anda. Dalam solusi IoT yang khas, pesan ini dikirimkan ke layanan hilir lainnya untuk penyimpanan atau analisis.

Pengarahan IoT Hub

Di hub IoT, Anda dapat mengonfigurasi perutean untuk mengirimkan pesan telemetri ke tujuan pilihan Anda. Tujuan meliputi:

• Wadah penyimpanan
• Service Bus queues
• Service Bus topics
• Pusat Aktivitas

Setiap hub IoT memiliki tujuan default yang disebut titik akhir bawaan. Layanan hilir dapat terhubung ke titik akhir bawaan untuk menerima pesan dari hub IoT.

Untuk mempelajari selengkapnya, lihat Menggunakan perutean pesan IoT Hub untuk mengirim pesan perangkat-ke-cloud ke titik akhir yang berbeda.

Anda dapat menggunakan kueri untuk memfilter pesan yang dikirim ke tujuan yang berbeda.

IoT Central routing

Jika Anda menggunakan Azure IoT Central, Anda dapat menggunakan ekspor data untuk mengirim pesan telemetri ke layanan hilir lainnya. Tujuan meliputi:

• Wadah penyimpanan
• Service Bus queues
• Service Bus topics
• Pusat Aktivitas
• Azure Data Explorer
• Webhooks

Konfigurasi ekspor data IoT Central memungkinkan Anda memfilter pesan yang dikirim ke tujuan.

Untuk mempelajari lebih lanjut, lihat Export data from IoT Central.

Jaringan Peristiwa

IoT Hub memiliki integrasi bawaan dengan Azure Event Grid. Hub IoT dapat menerbitkan peristiwa setiap kali menerima pesan telemetri dari perangkat. Anda dapat menggunakan Event Grid untuk merutekan peristiwa ini ke layanan lain.

Untuk mempelajari lebih lanjut, lihat Bereaksi terhadap acara IoT Hub dengan menggunakan Event Grid untuk memicu tindakan dan Bandingkan perutean pesan dan Event Grid untuk IoT Hub.

Memperkaya, mengubah, dan memproses pesan

Solusi berbasis Edge

Pengayaan dan transformasi dapat diterapkan pada data selama tahap pemrosesan untuk melakukan berbagai operasi. Operasi ini dapat mencakup:

• Menghitung properti baru: Berdasarkan properti yang sudah ada dalam pesan
• Mengganti nama properti: Untuk menstandarkan atau mengklarifikasi data
• Mengonversi unit: Mengonversi nilai ke unit pengukuran yang berbeda
• Menstandarkan nilai: Menskalakan nilai properti ke rentang yang ditentukan pengguna
• Kontekstualisasi data: Menambahkan data referensi ke pesan untuk pengayaan dan mendorong wawasan

Registri skema menyimpan skema untuk pesan yang berasal dari aset Anda. Aliran data menggunakan skema pesan ini untuk mendekode pesan dari berbagai format sehingga dapat diproses oleh aliran data.

Antarmuka pengguna web pengalaman operasi menyediakan lingkungan tanpa kode untuk membangun dan menjalankan transformasi dalam aliran data Anda.

Untuk mempelajari selengkapnya, lihat Memperkaya data dengan menggunakan aliran data.

Di Azure IoT Operations, Anda dapat menyebarkan aplikasi edge Anda sendiri yang sangat tersedia ke kluster Kubernetes. Aplikasi edge dapat berinteraksi dengan broker MQTT bawaan untuk:

• Gunakan logika pemrosesan pesan kustom pada pesan MQTT.
• Build custom application logic to run at the edge.
• Jalankan model AI Edge untuk pemrosesan data waktu nyata dan pengambilan keputusan langsung di sumber pembangkitan data, mengurangi latensi dan penggunaan bandwidth.

Untuk mempelajari lebih lanjut, lihat Develop highly available applications for Azure IoT Operations MQTT broker.

Solusi berbasis cloud

Untuk menyederhanakan pemrosesan hilir, Anda mungkin ingin menambahkan data ke pesan telemetri atau memodifikasi strukturnya.

Pengayaan pesan IoT Hub

Pengayaan pesan IoT Hub memungkinkan Anda menambahkan data ke pesan yang dikirim oleh perangkat Anda. Anda dapat menambahkan:

• A static string
• Nama hub IoT yang memproses pesan
• Information from the device twin

Untuk mempelajari lebih lanjut, lihat Peningkatan pesan untuk pesan IoT Hub device-to-cloud.

Transformasi pesan di IoT Central

IoT Central memiliki dua opsi untuk mengubah pesan telemetri:

• Gunakan pemetaan untuk mengubah telemetri perangkat yang kompleks menjadi data terstruktur pada ingress ke IoT Central.
• Gunakan transformasi untuk memanipulasi format dan struktur data perangkat sebelum Anda mengekspornya ke tujuan.

Pemrosesan pesan IoT Edge

Modul Azure IoT Edge dapat memproses telemetri dari sensor atau perangkat yang terpasang sebelum mengirimkannya ke hub IoT. Misalnya, sebelum mengirim data ke cloud, modul IoT Edge dapat:

• Filter data
• Data agregat
• Convert data
• Perform image classification at the edge

Layanan cloud lainnya

Anda dapat menggunakan layanan cloud lain untuk memproses pesan dari aset dan perangkat Anda.

Titik akhir aliran data di Operasi Azure IoT memungkinkan Anda terhubung ke layanan cloud untuk mengirim dan menerima data dari aset Anda. Titik akhir aliran data adalah titik koneksi untuk aliran data.

Untuk mempelajari selengkapnya, lihat:

• Mengonfigurasi titik akhir aliran data
• Mengonfigurasi aliran data pada Operasi Azure IoT

Di IoT Hub dan IoT Central, Anda dapat merutekan pesan ke layanan lain. Misalnya, Anda dapat meneruskan pesan ke Azure Stream Analytics untuk menganalisis dan memproses data streaming dalam volume besar atau Azure Functions untuk menjalankan kode sebagai respons terhadap peristiwa. Stream Analytics juga tersedia pada waktu proses Azure IoT Edge, yang memungkinkannya untuk memproses data di edge alih-alih di cloud.

Untuk mempelajari selengkapnya, lihat:

• Pengikatan Azure IoT Hub untuk Azure Functions
• Memvisualisasikan data sensor real-time dari Azure IoT Hub menggunakan Power BI
• Perluas Azure IoT Central dengan aturan kustom menggunakan Stream Analytics, Azure Functions, dan SendGrid

Konten terkait

• Memperluas solusi IoT Anda
• Menganalisis dan memvisualisasikan data IoT Anda
• Pilih layanan Azure IoT