Peneruskan data ke grup konsumen AMQP - IoT Platform

Anda dapat menggunakan mesin aturan untuk meneruskan pesan dari perangkat ke IoT Platform. Pesan tersebut diproses menggunakan skrip penguraian data, diteruskan ke grup konsumen AMQP, dan kemudian dikonsumsi oleh klien AMQP.Artikel ini menjelaskan proses penerusan data. Dalam contoh ini, topik komunikasi Thing Specification Language (TSL) digunakan sebagai topik sumber.

Prasyarat

Sumber data bernama DataSource telah dibuat dan topik komunikasi TSL telah ditambahkan ke sumber data. Untuk informasi lebih lanjut, lihat Buat Sumber Data.
Grup konsumen AMQP tujuan telah dibuat. Untuk informasi lebih lanjut, lihat Buat Grup Konsumen.

Buat tujuan data

Masuk ke Konsol IoT Platform.
Di halaman Overview, klik All environment. Pada tab All environment, temukan instance yang ingin Anda kelola dan klik ID atau nama instance.
Di panel navigasi sebelah kiri, pilih Message Forwarding > Data Forwarding.
Di pojok kanan atas halaman Data Forwarding, klik Go to New Version untuk masuk ke versi baru.
Catatan
Jika Anda telah melakukan langkah ini, halaman Data Forwarding versi baru akan muncul setelah Anda memilih Penerusan Pesan > Penerusan Data.
Klik Data Destination. Di tab Tujuan Data, klik Create Data Destination.

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

Select Operation

Parameter	Deskripsi
Pilih Operasi	Pilih Publish to AMQP Subscribed Consumer Group.
Grup Konsumen	Pilih grup konsumen yang ada sebagai tujuan penerusan data. Klik Create Consumer Group untuk membuat grup konsumen.

Konfigurasikan dan mulai parser

Buat parser bernama DataParser. Untuk informasi lebih lanjut, lihat Buat Parser.
Di halaman Parser Details, asosiasikan parser dengan sumber data yang telah dibuat.
1. Di langkah Data Source dalam wizard, klik Associate Data Source.
2. Di kotak dialog yang muncul, pilih DataSource dari daftar drop-down Data Source, lalu klik OK.
Di halaman Parser Details, asosiasikan parser dengan tujuan data yang telah dibuat.
1. Klik Data Destination dalam 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.
Di halaman parser details, klik Parser Script.

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

Untuk informasi lebih lanjut tentang parameter fungsi, lihat Fungsi.

// Gunakan fungsi payload() untuk mendapatkan data yang dikirimkan oleh perangkat dan mengubah data menggunakan format JSON. 
var data = payload("json");
// Teruskan data TSL yang dikirimkan. 
writeAmqp(1000, data, "debug");

Klik Debugging. Di panel yang muncul, pilih produk dan perangkat, tentukan topik, dan masukkan data payload untuk memeriksa apakah skrip berjalan sesuai harapan.
Gambar berikut menunjukkan parameter.
Hasil berikut menunjukkan bahwa skrip telah diimplementasikan.
Klik Publish.
Pergi ke tab Parser pada halaman Data Forwarding. Temukan parser DataParser dan klik Start di kolom Aksi untuk memulai parser.

Konfigurasikan klien AMQP untuk mengonsumsi pesan

Setelah data diteruskan ke grup konsumen AMQP, server Anda 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 berikut: