ApsaraMQ for MQTT:Kelola aturan masuk data

Cara kerja aturan masuk data

Aturan masuk data menjembatani topik RocketMQ ke topik MQTT. Setelah diaktifkan, pesan yang dipublikasikan ke topik RocketMQ akan diteruskan secara otomatis ke topik MQTT yang ditentukan dan dikirimkan ke klien MQTT yang berlangganan.

MQTT mendukung topik multi-level (misalnya, a/b/c), sedangkan RocketMQ hanya mendukung topik level tunggal. Untuk menjembatani perbedaan ini, topik MQTT level-1 dipetakan ke topik RocketMQ, dan level yang lebih dalam dipetakan ke properti pesan RocketMQ. Untuk logika pemetaan lengkap, lihat Pemetaan struktur pesan antara ApsaraMQ for MQTT dan ApsaraMQ for RocketMQ.

Prasyarat

Sebelum memulai, pastikan Anda telah memiliki:

• Instans ApsaraMQ for MQTT dengan versi kernel V3.x.x

• Instans ApsaraMQ for RocketMQ 4.0 di wilayah yang sama dengan instans MQTT

• Topik yang telah dibuat di kedua instans RocketMQ dan MQTT

Lihat versi kernel instans ApsaraMQ for MQTT di daftar instans atau pada halaman Instance Details di Konsol ApsaraMQ for MQTT.

Catatan penggunaan

Saat broker ApsaraMQ for RocketMQ sedang diperbarui, klien MQTT mungkin menerima pesan dengan latensi yang meningkat melalui aturan masuk data. Untuk jadwal pemeliharaan terjadwal, lihat Daftar Pemberitahuan.

Komponen aturan

Setiap aturan masuk data terdiri dari tiga bagian:

Buat aturan masuk data

1. Masuk ke Konsol ApsaraMQ for MQTT. Di panel navigasi kiri, klik Instances.

2. Di bilah navigasi atas, pilih wilayah instans target. Klik nama instans untuk membuka halaman Instance Details.

3. Di panel navigasi kiri, klik Rules. Di pojok kiri atas halaman Rules, klik Create Rule.

4. Pada langkah Configure Basic Information, atur parameter berikut lalu klik Next.

   Parameter	Example	Description
   Rule ID	111111	Pengidentifikasi unik global. Mendukung huruf, angka, tanda hubung (-), dan garis bawah (_). Harus mengandung setidaknya satu huruf atau angka. Panjang: 3–64 karakter. Dipotong otomatis jika lebih panjang. Tidak dapat diubah setelah dibuat.
   Description	migrate from rocketmq	Deskripsi teks untuk aturan tersebut.
   Status	Enable	Apakah akan segera mengaktifkan aturan. Nilai yang valid: Enable, Disable.
   Rule Type	Data Inbound	Pilih Data Inbound untuk mengimpor data dari layanan Alibaba Cloud lain ke ApsaraMQ for MQTT.

5. Pada langkah Configure Rule Source, tentukan sumber data lalu klik Next.

   Parameter	Example	Description
   Source Service Type	Message Queue for Apache RocketMQ	Layanan cloud tempat data diteruskan. Hanya ApsaraMQ for RocketMQ yang didukung.
   Message Queue for Apache RocketMQ Instance	MQ_INST_13801563067\*\*\*\*\*\_BbyOD2jQ	ID instans RocketMQ. Harus berada di wilayah yang sama dengan instans MQTT.
   Topic	Topic A	Topik RocketMQ yang pesannya diteruskan ke ApsaraMQ for MQTT.

6. Pada langkah Configure Rule Destination, tentukan topik MQTT target lalu klik Create.

   Parameter	Example	Description
   Topic	Topic B	Topik MQTT tempat data dikirimkan. Karena MQTT mendukung topik multi-level sedangkan RocketMQ tidak, topik MQTT level-1 dipetakan ke topik RocketMQ, dan level lainnya dipetakan ke properti pesan RocketMQ. Untuk detailnya, lihat Pemetaan struktur pesan antara ApsaraMQ for MQTT dan ApsaraMQ for RocketMQ.

Setelah aturan dibuat, aturan tersebut akan muncul di halaman Rules.

Kelola aturan yang ada

Di halaman Rules, temukan aturan target di daftar aturan. Di kolom Actions, pilih More, lalu pilih operasi yang diinginkan:

Topik terkait

• Untuk mengekspor data dari ApsaraMQ for MQTT ke layanan Alibaba Cloud lain, lihat Aturan keluar data.

• Untuk logika pemetaan pesan lengkap antara MQTT dan RocketMQ, lihat Pemetaan struktur pesan antara ApsaraMQ for MQTT dan ApsaraMQ for RocketMQ.

• Untuk mengekspor event koneksi dan pemutusan klien, lihat Ekspor event status klien ApsaraMQ for MQTT.