EventBridge:SMQ

Prosedur

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, lalu ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Setelah selesai, klik Save. Berikut adalah penjelasan parameter tersebut:

   • Pembuatan Tugas

     1. Di langkah Source, atur parameter Data Provider ke SMQ dan ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Lalu, klik Next Step. Tabel berikut menjelaskan parameter tersebut.

        Parameter	Deskripsi	Contoh
        Queue Name	Antrian SMQ yang Anda buat.	test-antrian
        Base64 Decoding	Menentukan apakah akan mengaktifkan penguraian Base64. Setelah Anda mengaktifkan penguraian Base64, data Anda di SMQ didekode dalam format Base64 sebelum dikirim ke layanan tujuan.	test
        Messages	Jumlah maksimum pesan yang dapat dikirim dalam setiap pemanggilan fungsi. Permintaan hanya dikirim ketika jumlah pesan dalam backlog mencapai nilai yang ditentukan. Nilai valid: 1 hingga 10000.	100
        Interval (Unit: Seconds)	Interval waktu saat Anda ingin memanggil fungsi. Sistem mengirimkan pesan teragregasi ke Function Compute ketika interval yang ditentukan tercapai. Nilai valid: 0 hingga 15. Satuan: detik. Nilai 0 menentukan bahwa pesan dikirim segera setelah agregasi.	3

     2. Di langkah Filtering, Transformation, dan Sink, konfigurasikan metode penyaringan acara, aturan transformasi acara, dan tujuan acara. Untuk informasi tentang konfigurasi transformasi acara, lihat Gunakan Function Compute untuk melakukan pembersihan pesan.

   • Properti Tugas

     Tentukan kebijakan ulang dan antrian pesan gagal untuk aliran acara. Untuk informasi lebih lanjut, lihat Kebijakan ulang dan antrian pesan gagal.

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

   Aliran acara memerlukan waktu 30 hingga 60 detik untuk diaktifkan. Anda dapat melihat kemajuan di kolom Status dari aliran acara pada halaman Event Streams.

Contoh acara

{
    "specversion":"1.0",
    "id":"bffb9722-9c48-407b-9895-b038f78f****",
    "source":"acs:mns",
    "type":"mns:Queue:SendMessage",
    "subject":"acs:mns:cn-hangzhou:123456789098****:queues/zeus",
    "datacontenttype":"application/json; charset=utf-8",
    "time":"2021-04-08T06:28:17.093Z",
    "aliyunpublishtime":"2021-04-08T06:30:31.367Z",
    "aliyuneventbusname":"mybus",
    "data":{
        "requestId":"606EA3074344430D4C81****",
        "messageId":"C6DB60D1574661357FA227277445****",
        "messageBody":"TEST"
    }
}

Untuk informasi tentang parameter yang didefinisikan dalam spesifikasi CloudEvents, lihat Ikhtisar.

Tabel berikut menjelaskan parameter yang terkandung dalam data.