Gunakan mesin aturan untuk meneruskan data dari IoT Platform ke ApsaraMQ for RocketMQ. Ini memastikan transmisi ujung-ke-ujung yang andal antara perangkat, IoT Platform, ApsaraMQ for RocketMQ, dan server aplikasi.
Prasyarat
Sebuah instance IoT Platform yang mendukung penerusan data ke ApsaraMQ for RocketMQ telah dibuat di wilayah yang sesuai. Untuk informasi lebih lanjut mengenai wilayah yang mendukung penerusan data ke ApsaraMQ for RocketMQ, lihat Wilayah.
Buat instance ApsaraMQ for RocketMQ dan topik untuk menerima data. Untuk panduan lebih lanjut, lihat Memulai dengan ApsaraMQ for RocketMQ.
PentingInstance ApsaraMQ for RocketMQ harus berada di wilayah yang sama dengan instance IoT Platform tempat Anda mengonfigurasi aturan penerusan data. Batasan ini tidak berlaku untuk aturan penerusan lintas wilayah yang sudah ada.
Anda hanya dapat meneruskan data ke topik instance ApsaraMQ for RocketMQ versi 4.x atau 5.x.
Konfigurasikan aturan penerusan data dan tulis pernyataan SQL untuk memproses data. Untuk detail lebih lanjut, lihat Mengonfigurasi Aturan Penerusan Data.
Peringatan
Gunakan versi baru atau sebelumnya dari fitur penerusan data untuk meneruskan data ke ApsaraMQ for RocketMQ. Untuk informasi lebih lanjut tentang versi baru, lihat Gunakan Versi Baru Fitur Penerusan Data untuk Meneruskan Data ke ApsaraMQ for RocketMQ.
Jika Anda menentukan Kirim Data ke ApsaraMQ for RocketMQ saat mengonfigurasi tujuan data, pengaturan berikut akan dikonfigurasi secara otomatis. Setelah konfigurasi selesai, Anda dapat meneruskan data perangkat ke instance ApsaraMQ for RocketMQ V5.0 menggunakan mesin aturan IoT Platform.
Dua alamat IP dari vSwitch tempat instance ApsaraMQ for RocketMQ terhubung dialokasikan ke IoT Platform.
Grup keamanan yang dikelola dibuat di virtual private cloud (VPC) tempat instance ApsaraMQ for RocketMQ berada. Secara default, nama grup keamanan dimulai dengan sg-nsm-.
Prosedur
- Masuk ke Konsol IoT Platform.
Di halaman Overview, klik All environment. Di tab Semua Lingkungan, temukan instance yang ingin Anda kelola dan klik ID atau nama instance tersebut.
- Di panel navigasi sisi kiri, pilih .
- Klik View di sebelah aturan yang ingin Anda kelola. Halaman Data Forwarding Rule akan muncul.Penting Jika versi baru halaman Penerusan Data ditampilkan, klik Back to Previous Version di pojok kanan atas, lalu klik View di kolom Tindakan aturan yang ingin Anda kelola.
- Di bagian Forward Data, klik Add Operation.
Di kotak dialog Add Operation, pilih Send Data to ApsaraMQ for Apache RocketMQ dari daftar drop-down Operasi. Konfigurasikan parameter lain sesuai petunjuk dan klik OK. Tabel berikut menjelaskan parameter tersebut.
Parameter
Deskripsi
Operasi
Pilih Send Data to ApsaraMQ for RocketMQ.
Wilayah
Pilih wilayah tempat instance ApsaraMQ for RocketMQ berada.
Instance
Pilih instance ApsaraMQ for RocketMQ.
Anda dapat mengklik Create Instance untuk pergi ke konsol ApsaraMQ for RocketMQ dan membuat instance ApsaraMQ for RocketMQ. Untuk informasi lebih lanjut, lihat Dokumentasi ApsaraMQ for RocketMQ.
Topik
Pilih topik ApsaraMQ for RocketMQ yang ingin Anda gunakan untuk menerima data dari IoT Platform.
Anda dapat mengklik Create Topic untuk pergi ke konsol ApsaraMQ for RocketMQ dan membuat topik ApsaraMQ for RocketMQ.
Tag
Opsional. Tentukan tag.
Jika Anda menentukan tag, tag tersebut akan dilampirkan ke semua pesan yang diteruskan ke topik ApsaraMQ for RocketMQ. Anda dapat memfilter pesan berdasarkan tag pada klien konsumen Anda.
Panjang maksimum tag adalah 128 byte. Anda dapat memasukkan konstanta atau variabel. Tentukan variabel dalam format ${key}. ${key} menentukan bahwa variabel merujuk pada nilai kunci dalam hasil JSON dari pernyataan SQL.
Otorisasi
Berikan IoT Platform izin untuk menulis data ke ApsaraMQ for RocketMQ.
Jika Anda tidak memiliki Peran RAM, klik Create RAM Role untuk pergi ke konsol RAM, buat peran RAM, lalu berikan izin kepada peran tersebut. Untuk informasi lebih lanjut, lihat Buat Peran RAM.
- Pergi ke halaman Data Forwarding, temukan aturan yang Anda kelola, lalu klik Start di kolom Tindakan aturan tersebut.
Lakukan uji coba.
Publikasikan pesan ke topik yang didefinisikan dalam pernyataan SQL yang dikonfigurasikan dalam aturan penerusan data. Kemudian, buka Konsol ApsaraMQ for RocketMQ untuk memeriksa apakah pesan tersebut diterima.
Contoh
Meneruskan data perangkat ke server bisnis menggunakan ApsaraMQ for RocketMQ