全部产品
Search
文档中心

IoT Platform:Meneruskan data ke grup konsumen AMQP

更新时间:Jul 02, 2025

Anda dapat menggunakan mesin aturan untuk meneruskan pesan yang dikirim oleh perangkat ke IoT Platform. Pesan-pesan tersebut diproses menggunakan pernyataan SQL, diteruskan ke grup konsumen Advanced Message Queuing Protocol (AMQP), dan kemudian dikonsumsi oleh klien AMQP.

Prasyarat

  • Aturan penerusan data telah dibuat dan pernyataan SQL untuk memproses data telah ditulis. Untuk informasi lebih lanjut, lihat Konfigurasikan Aturan Penerusan Data.
  • Grup konsumen AMQP telah dibuat dan digunakan sebagai tujuan penerusan data. Untuk informasi lebih lanjut tentang cara membuat dan mengelola grup konsumen, lihat Kelola Grup Konsumen.

Prosedur

  1. Masuk ke Konsol IoT Platform.
  2. Di halaman Overview, klik All environment. Pada tab All environment, temukan instance yang ingin Anda kelola dan klik ID atau nama instance tersebut.

  3. Di panel navigasi sebelah kiri, pilih Message Forwarding > Data Forwarding.
  4. Klik View di samping aturan yang ingin Anda kelola. Halaman Data Forwarding Rule akan muncul.
    Penting Jika versi baru halaman Data Forwarding ditampilkan, klik Back to Previous Version di pojok kanan atas, lalu klik View di kolom Actions dari aturan yang ingin Anda kelola.
  5. Di bagian Forward Data, klik Add Operation.
  6. Di kotak dialog Add Operation, pilih Publish to AMQP Subscribed Consumer Group. Atur parameter yang diperlukan sesuai dengan prompt dan klik OK.
    Add Operation
    ParameterDeskripsi
    Pilih OperasiPilih Publish to AMQP Subscribed Consumer Group.
    Grup KonsumenPilih grup konsumen yang ada sebagai tujuan penerusan data. Klik Create Consumer Group untuk membuat grup konsumen.
    TagJika Anda menetapkan tag, tag tersebut akan ditambahkan ke semua pesan yang diteruskan oleh operasi ini ke grup konsumen AMQP.
    Tag harus memiliki panjang 1 hingga 128 karakter. Anda dapat menentukan konstanta atau variabel.
    • Konstanta dapat berisi huruf dan angka.
    • Jika Anda menentukan variabel, gunakan format ${key}. ${key} menunjukkan bahwa variabel merujuk pada nilai dari sebuah key dalam hasil JSON dari pernyataan SQL. Jika nilainya tidak tersedia, tag tidak akan ditambahkan ke pesan.
  7. Buka halaman Data Forwarding, temukan aturan yang Anda kelola, lalu klik Start di kolom Actions dari aturan tersebut.

Konfigurasikan klien AMQP untuk mengonsumsi pesan

Setelah data diteruskan ke grup konsumen AMQP, server Anda dapat mengonsumsi pesan menggunakan klien AMQP. Untuk informasi lebih lanjut tentang cara mengonfigurasi klien AMQP, lihat Hubungkan Klien AMQP ke IoT Platform.

Untuk contoh kode implementasi klien AMQP, lihat topik-topik berikut: