Tutorial: Menerbitkan ulang pesan MQTT

Buka hub AturanAWS 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.

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

2. Dalam Deskripsi, jelaskan aturannya.

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

Dalam pernyataan kueri Aturan Buat aturan:

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

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

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

   Pernyataan ini:

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

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

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

Di Tetapkan satu atau lebih tindakan:

1. Untuk membuka daftar tindakan aturan untuk aturan ini, pilih Tambah tindakan.

2. Di Pilih tindakan, pilih Menerbitkan 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 MQTT topik pesan yang akan dipublikasikan oleh aturan ini.

2. Di Quality of Service, pilih 0 - Pesan dikirim nol kali atau lebih.

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

   1. Pilih Buat Peran. Kotak 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 guna mengotorisasi topik atau tindakan baru. Untuk memperbarui peran yang ada, pilih Perbarui peran di bagian ini.

   3. Pilih Buat Peran untuk membuat peran dan menutup kotak dialog.

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

Menerbitkan ulang pesan ke tindakan AWS IoT topik sekarang tercantum dalam Tetapkan satu atau beberapa tindakan.

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

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

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

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

1. Di MQTT klien, di bawah Langganan, pilih Berlangganan topik.

2. Dalam topik Langganan, masukkan topik filter topik masukan,device/+/data.

3. Simpan sisa bidang di pengaturan defaultnya.

4. Pilih Berlangganan topik.

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

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

1. Di bawah Langganan, pilih Berlangganan topik lagi, dan dalam topik Langganan, masukkan topik pesan yang diterbitkan ulang,. device/data/temp

2. Simpan sisa bidang di pengaturan defaultnya.

3. Pilih Berlangganan topik.

   Di kolom Langganan, 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 MQTT topik yang berisi karakter wildcard.

1. Di MQTT klien, di bawah Langganan, pilih Publikasikan 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 MQTT pesan, pilih Publikasikan ke topik.

Tinjau pesan yang dikirim.

1. Di MQTT klien, di bawah Langganan, 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 muatan pesan cocok dengan apa yang baru saja Anda terbitkan dan terlihat seperti ini:

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

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

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

   Perhatikan bahwa device_id nilainya adalah string yang dikutip dan temperature nilainya numerik. Hal ini karena topic()fungsi mengekstrak string dari nama topik pesan masukan sementara temperature nilai menggunakan nilai numerik dari payload pesan masukan.

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

   cast(topic(2) AS DECIMAL)

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

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

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