Tutorial: Menerbitkan ulang pesan MQTT

Buka hub A turan AWS IoT konsol.

Di Aturan, pilih Buat dan mulai membuat aturan baru Anda.

Di bagian atas Buat aturan:

1. Di Nama, masukkan nama aturan. Untuk tutorial ini, beri namarepublish_temp.

   Ingatlah bahwa nama aturan harus unik dalam Akun dan Wilayah Anda, dan tidak boleh memiliki spasi. Kami telah menggunakan karakter garis bawah dalam nama ini untuk memisahkan dua kata dalam nama aturan.

2. Dalam Deskripsi, jelaskan aturannya.

   Deskripsi yang berarti membantu Anda mengingat apa yang dilakukan aturan ini dan mengapa Anda membuatnya. Deskripsinya bisa selama dibutuhkan, jadi sedetail mungkin.

Dalam pernyataan kueri aturan Buat aturan:

1. Di Menggunakan versi SQL, pilih2016-03-23.

2. Di kotak edit pernyataan kueri aturan, masukkan pernyataan:

   SELECT topic(2) as device_id, temperature FROM 'device/+/data'

   Pernyataan ini:

   • Mendengarkan pesan MQTT dengan topik yang cocok dengan filter device/+/data topik.

   • Memilih elemen kedua dari string topik dan menetapkannya ke device_id bidang.

   • Memilih temperature bidang nilai dari payload pesan dan menetapkannya ke bidang. temperature

Dalam Mengatur satu atau lebih tindakan:

1. Untuk membuka daftar tindakan aturan untuk aturan ini, pilih Tam bah tindakan.

2. Di Pilih tindakan, pilih Publi kasikan ulang pesan ke AWS IoT topik.

3. Di bagian bawah daftar tindakan, pilih Konfigurasi tindakan untuk membuka halaman konfigurasi tindakan yang dipilih.

Dalam tindakan Konfigurasi:

1. Di Topik, masukkandevice/data/temp. Ini adalah topik MQTT dari pesan yang akan diterbitkan aturan ini.

2. Di Kualitas Layanan, pilih 0 - Pesan dikirimkan nol kali atau lebih.

3. Di Pilih atau buat peran untuk memberikan AWS IoT akses untuk melakukan tindakan ini:

   1. Pilih Buat Peran. Ko tak dialog Buat peran baru terbuka.

   2. Masukkan nama yang menggambarkan peran baru. Dalam tutorial ini, gunakanrepublish_role.

      Saat Anda membuat peran baru, kebijakan yang benar untuk melakukan tindakan aturan dibuat dan dilampirkan ke peran baru. Jika Anda mengubah topik tindakan aturan ini atau menggunakan peran ini dalam tindakan aturan lain, Anda harus memperbarui kebijakan untuk peran tersebut untuk mengotorisasi topik atau tindakan baru. Untuk memperbarui peran yang ada, pilih Per barui peran di bagian ini.

   3. Pilih Buat Per an untuk membuat peran dan menutup kotak dialog.

4. Pilih Tam bah tindakan untuk menambahkan tindakan ke aturan dan kembali ke halaman Buat aturan.

Tind akan Publikasikan ulang pesan ke AWS IoT topik sekarang tercantum di Tet apkan satu atau beberapa tindakan.

Di ubin tindakan baru, di bawah Publikasikan ulang pesan ke AWS IoT topik, Anda dapat melihat topik yang akan dipublikasikan tindakan penerbitan ulang Anda.

Ini adalah satu-satunya tindakan aturan yang akan Anda tambahkan ke aturan ini.

Di Buat aturan, gulir ke bawah dan pilih Buat aturan untuk membuat aturan dan selesaikan langkah ini.

Di klien MQTT di AWS IoT konsol, berlangganan topik input, dalam hal ini,device/+/data.

1. Di klien MQTT, di bawah Lang ganan, pilih Berlangganan ke topik.

2. Di Topik berlangganan, masukkan topik filter topik masukan,device/+/data.

3. Simpan sisa bidang pada pengaturan defaultnya.

4. Pilih Berlangganan topik.

   Di kolom Langganan, di bawah Publikasikan ke topik, device/+/data muncul.

Berlangganan topik yang akan diterbitkan aturan Anda:device/data/temp.

1. Di bawah Lang ganan, pilih Ber langganan ke topik lagi, dan di Topik langganan, masukkan topik pesan yang diterbitkan ulang,device/data/temp.

2. Simpan sisa bidang pada pengaturan defaultnya.

3. Pilih Berlangganan topik.

   Di kolom Lang ganan, di bawah perangkat /+/data, muncul. device/data/temp

Publikasikan pesan ke topik input dengan ID perangkat tertentu,device/22/data. Anda tidak dapat mempublikasikan ke topik MQTT yang berisi karakter wildcard.

1. Di klien MQTT, di bawah Lang ganan, pilih Publi kasikan ke topik.

2. Di bidang Publikasikan, masukkan nama topik masukan,device/22/data.

3. Salin data sampel yang ditampilkan di sini dan, di kotak edit di bawah nama topik, tempel data sampel.

   {
     "temperature": 28,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

4. Untuk mengirim pesan MQTT Anda, pilih Publi kasikan ke topik.

Tinjau pesan yang dikirim.

1. Di klien MQTT, di bawah Lang ganan, ada titik hijau di sebelah dua topik yang Anda berlangganan sebelumnya.

   Titik-titik hijau menunjukkan bahwa satu atau lebih pesan baru telah diterima sejak terakhir kali Anda melihatnya.

2. Di bawah Langganan, pilih perangkat/+/data untuk memeriksa apakah payload pesan cocok dengan apa yang baru saja Anda publikasikan dan terlihat seperti ini:

   {
     "temperature": 28,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

3. Di bawah Langganan, pilih device/data /temp untuk memeriksa apakah payload pesan yang diterbitkan ulang terlihat seperti ini:

   {
     "device_id": "22",  
     "temperature": 28
   }

   Perhatikan bahwa nil device_id ainya adalah string yang dikutip dan nil temperature ainya numerik. Ini karena topic() fungsi mengekstrak string dari nama topik pesan input sementara nilainya menggunakan temperature nilai numerik dari payload pesan input.

   Jika Anda ingin menjadikan nilai device_id sebagai nilai numerik, ganti topic(2) pernyataan kueri aturan dengan:

   cast(topic(2) AS DECIMAL)

   Perhatikan bahwa memasukkan topic(2) nilai ke nilai numerik hanya akan berfungsi jika bagian topik itu hanya berisi karakter numerik.

Jika Anda melihat bahwa pesan yang benar telah dipublikasikan ke topik device/data /temp, maka aturan Anda berfungsi. Lihat apa lagi yang dapat Anda pelajari tentang tindakan Publikasikan ulang aturan di bagian berikutnya.

Jika Anda tidak melihat bahwa pesan yang benar telah dipublikasikan ke topik perangkat /+/data atau device/data /temp, periksa kiat pemecahan masalah.