IoT Platform：Peneruskan Data ke Message Queue untuk Apache RocketMQ

Catatan Penggunaan

• Anda dapat menggunakan fitur penerusan data versi baru atau sebelumnya untuk meneruskan data ke Message Queue untuk Apache RocketMQ. Untuk informasi lebih lanjut tentang cara menggunakan fitur penerusan data versi sebelumnya, lihat Peneruskan Data ke ApsaraMQ untuk RocketMQ.

• Jika Anda menentukan Kirim Data ke ApsaraMQ untuk RocketMQ saat mengonfigurasi tujuan data, pengaturan berikut akan dikonfigurasikan secara otomatis. Setelah konfigurasi selesai, Anda dapat meneruskan data perangkat ke instance ApsaraMQ untuk RocketMQ V5.0 Anda menggunakan mesin aturan IoT Platform.

  • Dua alamat IP dari vSwitch tempat instance ApsaraMQ untuk RocketMQ terhubung dialokasikan ke IoT Platform.

  • Sebuah grup keamanan terkelola dibuat di virtual private cloud (VPC) tempat instance ApsaraMQ untuk RocketMQ berada. Secara default, nama grup keamanan dimulai dengan sg-nsm-.

Buat Tujuan Data

1. Masuk ke Konsol IoT Platform.

2. Di halaman Overview, klik All environment. Di tab Semua Lingkungan, temukan instance yang ingin Anda kelola dan klik ID instance atau nama instance.

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

4. Di pojok kanan atas halaman Data Forwarding, klik Go to New Version untuk beralih ke versi baru.

   Catatan

   Jika Anda telah melakukan langkah ini, halaman Data Forwarding versi baru akan muncul setelah Anda memilih Penerusan Pesan > Penerusan Data.

5. Klik Data Destination. Di tab Tujuan Data, klik Create Data Destination.

6. Di kotak dialog Create Data Destination, masukkan nama tujuan data. Dalam contoh ini, DataPurpose digunakan. Konfigurasikan parameter dan klik OK.

   

   Parameter	Deskripsi
   Operasi	Pilih Send Data to ApsaraMQ for RocketMQ.
   Wilayah	Pilih wilayah tempat instance ApsaraMQ untuk RocketMQ berada.
   Instance	Pilih instance ApsaraMQ untuk RocketMQ. Anda dapat mengklik Create Instance untuk pergi ke konsol ApsaraMQ untuk RocketMQ dan membuat instance ApsaraMQ untuk RocketMQ. Untuk informasi lebih lanjut, lihat Dokumentasi ApsaraMQ untuk RocketMQ.
   Topik	Pilih topik ApsaraMQ untuk RocketMQ yang ingin Anda gunakan untuk menerima data dari IoT Platform. Anda dapat mengklik Create Topic untuk pergi ke konsol ApsaraMQ untuk RocketMQ dan membuat topik ApsaraMQ untuk RocketMQ.
   Berikan izin	Berikan IoT Platform izin untuk menulis data ke ApsaraMQ untuk RocketMQ. Jika Anda tidak memiliki Peran RAM, klik Create RAM Role untuk pergi ke konsol RAM, buat peran RAM, dan kemudian berikan izin ke peran tersebut. Untuk informasi lebih lanjut, lihat Buat Peran RAM.

Konfigurasikan dan Mulai Parser

1. Buat parser bernama DataParser. Untuk informasi lebih lanjut, lihat Buat Parser.

2. Di halaman Parser Details, asosiasikan parser dengan sumber data yang telah dibuat.

   1. Di langkah Data Source wizard, klik Associate Data Source.

   2. Di kotak dialog yang muncul, pilih DataSource dari daftar drop-down Data Source, lalu klik OK.

3. Di halaman Parser Details, asosiasikan parser dengan tujuan data yang telah dibuat.

   1. Klik Data Destination di wizard. Di bagian Data Destination, klik Associate Data Destination.

   2. Di kotak dialog yang muncul, pilih DataPurpose dari daftar drop-down Data Destination, lalu klik OK.

   3. Di bagian Tujuan Data, lihat dan simpan data destination ID. Dalam contoh ini, ID adalah 1000.

      Saat menulis skrip parser, Anda harus menggunakan data destination ID.

4. Di halaman parser details, klik Parser Script.

5. Di editor kode, masukkan skrip. Untuk informasi lebih lanjut tentang cara memodifikasi skrip, lihat Sintaks Skrip.

   Untuk informasi lebih lanjut tentang parameter fungsi, lihat Fungsi.

   // Gunakan fungsi payload() untuk mendapatkan data yang dikirim oleh perangkat dan mengonversi data menjadi format JSON.
   var data = payload("json");
   // Teruskan data TSL yang dikirim.
   writeMq(1000, data, "debug");

6. Klik Debugging. Di panel yang muncul, pilih produk dan perangkat, tentukan topik, lalu masukkan data payload untuk memeriksa apakah skrip berjalan sesuai harapan.

   Gambar berikut menunjukkan parameter.

   Hasil berikut menunjukkan bahwa skrip berjalan sesuai harapan.

   

7. Klik Publish.

8. Pergi ke tab Parser pada halaman Data Forwarding. Temukan parser DataParser dan klik Start di kolom Tindakan untuk memulai parser.

9. Di Konsol Message Queue untuk Apache RocketMQ, periksa apakah pesan diterima.