EventBridge:Mengarahkan event ke SMQ

Buat aliran event

1. Masuk ke konsol EventBridge. Di panel navigasi sebelah kiri, klik Event Streams.

2. Di bilah navigasi atas, pilih wilayah dan klik Create Event Stream.

3. Di halaman Create Event Stream, konfigurasikan parameter Task Name dan Description, serta ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Lalu, klik Save. Bagian berikut menjelaskan parameter tersebut:

   • Pembuatan Tugas

     1. Di langkah Source, Filtering, dan Transformation, tentukan sumber event, metode penyaringan, dan aturan transformasi. Lalu, klik Next Step. Untuk informasi tentang konfigurasi transformasi event, lihat Gunakan Function Compute untuk Melakukan Pembersihan Pesan.

     2. Di langkah Sink, atur parameter Service Type ke SMQ dan ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Tabel berikut menjelaskan parameter tersebut.

        Parameter	Deskripsi	Contoh
        Queue Name	Antrian SMQ yang Anda buat.	test
        Enable Base64 Encoding	Tentukan apakah akan mengaktifkan pengkodean Base64. Jika Anda menonaktifkan fitur ini, pesan yang Anda terima berisi karakter tidak jelas.	Ya
        Message Body	Metode yang ingin Anda gunakan untuk mentransformasi event. Untuk informasi lebih lanjut, lihat Transformasi event.	Event Lengkap

   • Properti Tugas

     Konfigurasikan kebijakan ulang dan antrian pesan gagal untuk aliran event. Untuk informasi lebih lanjut, lihat Kebijakan Ulang dan Antrian Pesan Gagal.

4. Kembali ke halaman Event Streams dan temukan aliran event yang Anda buat. Lalu, klik Enable di kolom Actions.

   Mengaktifkan aliran event membutuhkan waktu 30 hingga 60 detik untuk selesai. Anda dapat melihat kemajuannya di kolom Status dari aliran event di halaman Event Streams.

Verifikasi hasil

Anda dapat memeriksa apakah event diterima di konsol SMQ.

1. Masuk ke konsol SMQ. Di panel navigasi sebelah kiri, pilih Queue Model > Queues.

2. Di bilah navigasi atas, pilih wilayah.

3. Di halaman Queues, temukan antrian ke mana Anda mengarahkan event dan pilih More > Send Messages di kolom Actions.

4. Di bagian Receive Message dari halaman Quick Experience, klik Receive Message.

   Kode contoh berikut memberikan contoh event yang diterima:

   {
       "data":{
          "props":{
               "firstTopic":"topci12****",
               "secondTopic":"",
               "clientId":"GID_MQTT_CONSOLE@@@lmqhb1share01vpc165759566****"
          },
          "body":"Halo Dunia"
       },
       "id":"AC11C08E76C67E7740853B0F604D****",
       "source":"acs:mqtt",
       "specversion":"1.0",
       "type":"mqtt:Topic:SendMessage",
       "datacontenttype":"application/json; charset\u003dutf-8",
       "time":"2022-07-12T03:14:23.447Z",
       "subject":"acs:mq:cn-qingdao:182572506381****:topic/mqtt-cn-2r42rdr****/topci12****",
       "aliyunaccountid":"182572506381****"
   }