IoT Platform:Meneruskan data ke ApsaraMQ for RocketMQ

Cara kerja

Penerusan data mengirimkan pesan perangkat ke client ApsaraMQ for RocketMQ untuk dikonsumsi.

1. Server aplikasi: Daftarkan konsumen menggunakan SDK ApsaraMQ for RocketMQ untuk menerima pesan.

2. IoT Platform: Konfigurasikan penerusan data untuk mengarahkan pesan perangkat ke ApsaraMQ for RocketMQ.

   • Topik sumber data: Kategori topik yang didukung tercantum dalam Format data.

   • Ekspresi SQL: Tulis ekspresi SQL untuk mengurai dan memproses data JSON dari perangkat. Ekspresi SQL.

     Catatan

     Data dalam format biner diteruskan tanpa diurai.

   • Tujuan data: Topik ApsaraMQ for RocketMQ yang menerima pesan perangkat. Buat topik tersebut terlebih dahulu di konsol ApsaraMQ for RocketMQ. Buat topik.

     Anda dapat memberi tag pada pesan perangkat untuk pemfilteran di sisi konsumen.

3. ApsaraMQ for RocketMQ: Saat konsumen mengambil pesan, ApsaraMQ for RocketMQ melakukan pemfilteran di sisi server dan hanya mengirimkan pesan yang sesuai ke server aplikasi.

Batasan

• Penerusan data ke ApsaraMQ for RocketMQ hanya tersedia di wilayah tertentu. Fitur berdasarkan wilayah.

• Instans ApsaraMQ for RocketMQ harus berada di wilayah yang sama dengan instans IoT Platform. Konfigurasi cross-region yang sudah ada tidak terpengaruh dan tetap berfungsi seperti biasa.

• Anda hanya dapat meneruskan data ke topik dalam instans seri ApsaraMQ for RocketMQ 4.x atau 5.x. Instans serverless tidak didukung. Untuk topik dalam instans ApsaraMQ for RocketMQ 5.x, Message Type harus berupa Normal Message.

• Versi baru maupun versi sebelumnya dari penerusan data sama-sama mendukung ApsaraMQ for RocketMQ. Meneruskan data ke ApsaraMQ for RocketMQ (versi baru).

• Versi sebelumnya dari penerusan data tidak mendukung produk dan perangkat yang dikelola oleh produk cloud gateway atau yang menggunakan instans berbasis MQTT. Gunakan Penerusan data (versi baru) untuk produk dan perangkat tersebut.

Konfigurasi otomatis untuk RocketMQ 5.0

Saat menggunakan ApsaraMQ for RocketMQ 5.0, konfigurasi berikut akan dilakukan secara otomatis setelah Anda menetapkan tujuan data:

• IoT Platform menempati dua alamat IP dari vSwitch instans ApsaraMQ for RocketMQ.

• Grup keamanan terkelola (nama dengan awalan sg-nsm-) dibuat di VPC instans ApsaraMQ for RocketMQ.

Konfigurasikan tujuan data

1. Masuk ke Konsol IoT Platform.

2. Di halaman Overview, temukan instans yang ingin Anda kelola lalu klik ID instans atau nama instans tersebut.

3. Di panel navigasi sebelah kiri, pilih Message Forwarding > Data Forwarding.

4. Klik View di sebelah aturan target. Halaman Data Forwarding Rule akan muncul.

   Penting

   Jika halaman Data Forwarding (New Version) ditampilkan, klik Back to Previous Version di pojok kanan atas, lalu klik View di sebelah aturan target.

5. Di bagian Forward Data, klik Add Operation.

6. Di kotak dialog Add Operation, pilih Forward data to ApsaraMQ for RocketMQ. Atur parameter lainnya sesuai petunjuk lalu klik OK.

   Parameter	Deskripsi
   Select an operation	Pilih Forward data to ApsaraMQ for RocketMQ.
   Region	Pilih wilayah instans ApsaraMQ for RocketMQ.
   Instance	Pilih instans ApsaraMQ for RocketMQ. Klik Create Instance untuk membuat instans di konsol ApsaraMQ for RocketMQ. Dokumentasi ApsaraMQ for RocketMQ.
   Topic	Pilih topik ApsaraMQ for RocketMQ untuk menerima data dari IoT Platform. Klik Create Topic untuk membuat topik di konsol ApsaraMQ for RocketMQ.
   Tag	(Opsional) Tetapkan tag. Semua pesan yang diteruskan oleh operasi ini membawa tag tersebut, yang dapat digunakan konsumen untuk pemfilteran. Panjang maksimum: 128 byte. Mendukung konstanta atau variabel dalam format ${key}, di mana key dipetakan ke bidang dalam data JSON hasil pemrosesan SQL.
   Authorization	Berikan akses tulis IoT Platform ke ApsaraMQ for RocketMQ. Jika belum ada Peran RAM, klik Create RAM Role untuk membuat Peran RAM dan kebijakan otorisasi di konsol RAM. Buat Peran RAM.

7. Di halaman Data Forwarding, temukan aturan tersebut lalu klik Start di kolom Actions.

8. Uji

   Publikasikan pesan ke topik yang didefinisikan dalam pernyataan SQL aturan, lalu periksa log penerusan.

Lihat log penerusan

1. Di Konsol IoT Platform, klik instans Enterprise target untuk melihat status perangkat dan log penerusan pesan. Untuk informasi selengkapnya, lihat Log platform IoT.

2. Di terminal server aplikasi yang berlangganan sumber daya ApsaraMQ for RocketMQ, lihat log langganan dan konsumsi pesan.

3. Di Konsol ApsaraMQ for RocketMQ, di halaman Instance Details, lihat konten dan jejak pesan yang diterima oleh konsumen. Untuk informasi selengkapnya, lihat Kueri jejak pesan.