EventBridge:Berlangganan event ECS dengan EventBridge

Latar Belakang

Skenario

• Berlangganan event ECS tertentu untuk memicu notifikasi melalui DingTalk, SMS, atau email.

• Dorong event ECS tertentu ke layanan HTTP atau HTTPS downstream melalui Internet atau Virtual Private Cloud (VPC).

• Agregasikan event ECS dari beberapa Akun Alibaba Cloud.

• Picu aksi tertentu menggunakan Function Compute saat event ECS tertentu terjadi.

• Jika event ECS memiliki latensi tinggi atau volume besar, kirimkan ke Simple Message Queue (formerly MNS) untuk berlangganan event.

Prasyarat

• Aktifkan EventBridge dan berikan izin yang diperlukan.

• Buat chatbot DingTalk dan catat URL webhook serta token rahasia-nya.

• Buat layanan dan fungsi. Untuk informasi selengkapnya, lihat Kelola layanan dan Kelola fungsi.

• Buat antrian Simple Message Queue (formerly MNS). Untuk informasi selengkapnya, lihat Aktifkan SMQ dan berikan izin dan Buat antrian.

Langkah 1: Gunakan event bus default

EventBridge memiliki event bus default untuk layanan cloud bernama default. Layanan Alibaba Cloud mengirimkan event ke bus default tersebut secara real time melalui berbagai saluran. Anda dapat menemukan dan berlangganan event dari layanan cloud pada bus default ini.

Langkah 2: Buat aturan event ECS

1. Pada halaman Event Buses, klik Event Rules di panel navigasi kiri, lalu klik Create Rule.

2. Pada panel Create Rule, lakukan langkah-langkah berikut.

   1. Pada tab Configure Basic Info, masukkan nama aturan di bidang Name dan deskripsi di bidang Description. Lalu, klik Next.

   2. Pada tab Configure Event Pattern, konfigurasikan parameter berikut dan klik Next.

      • Klik tab Alibaba Cloud Service Event Sources.

      • Dari daftar drop-down Event Source, pilih acs.ecs.

      • Dari daftar drop-down Event Type, pilih satu atau beberapa jenis event untuk dilanggankan.

      • Pada bagian Event Pattern Debugging, lihat contoh event. Misalnya, jika Anda memilih ecs:Instance:StateChange sebagai jenis event, contoh berikut akan ditampilkan.

        {
          "id": "45ef4dewdwe1-7c35-447a-bd93-fab****",
          "source": "acs.ecs",
          "specversion": "1.0",
          "subject": "acs.ecs:cn-hangzhou:123456789098****:215672",
          "time": "2020-11-19T21:04:41Z",
          "type": "ecs:Instance:StateChange",
          "aliyunaccountid": "123456789098****",
          "aliyunpublishtime": "2020-11-19T21:04:42Z",
          "aliyuneventbusname": "default",
          "aliyunregionid": "cn-hangzhou",
          "aliyunpublishaddr": "172.25.XX.XX",
          "data": {
            "instanceName": "iZ0jl0kyquo46h****",
            "instanceType": "ecs.c6.large",
            "privateIpAddress": "172.21.XX.XX",
            "publicIpAddress": "8.37.XX.XX",
            "resourceId": "i-0jl0kyquo46****",
            "resourceType": "ALIYUN::ECS::Instance",
            "spotStrategy": "SpotWithPriceLimit",
            "state": "Running"
          }
        }

   3. Pada tab Configure Targets, pilih Service Type untuk mengonfigurasi skenario pengiriman.

      Simple Message Queue (formerly MNS)

      Mendorong event ke Simple Message Queue (formerly MNS) cocok untuk skenario dengan persyaratan latensi rendah atau volume event tinggi. Untuk informasi selengkapnya mengenai harga Simple Message Queue (formerly MNS), lihat Billing.

      • Service Type: Pilih Simple Message Queue (formerly MNS).

      • Queue: Pilih antrian yang sudah ada.

      • Message Body: Pilih Complete Event.

      • Enable Base64 Decoding: Pilih Yes. Ini memastikan bahwa data event dikirimkan dalam format terenkripsi Base64 ke antrian target di Simple Message Queue (formerly MNS).

      Jika tipe layanan adalah Simple Message Queue (formerly MNS), Anda dapat menggunakan paket NetworkInterfaceDemo.zip untuk mendengarkan pesan Simple Message Queue (formerly MNS) dan mendapatkan event.

      DingTalk

      • Service Type: Pilih DingTalk.

      • Webhook URL: Masukkan URL webhook chatbot DingTalk.

      • Secret Key: Masukkan token rahasia chatbot DingTalk.

      • Content to Push: Anda dapat menggunakan templat EventBridge untuk mendorong parameter dari event ke chatbot DingTalk. Misalnya, untuk mendorong nama instans ECS (instanceName) dan statusnya (state), konfigurasikan parameter berikut:

        • Variables: Gunakan JSONPath untuk mengekstraksi bidang dari event dan menentukan nama variabel.

          {
            "instanceName":"$.data.instanceName",
            "state":"$.data.state"
          }

        • Template: Tentukan templat dalam format yang dibutuhkan oleh chatbot DingTalk dan referensikan variabel yang telah Anda definisikan.

          {
            "msgtype": "text",
            "text": {
                "content": "${instanceName} state is ${state}" 
            } 
          }

      HTTP service

      • Service Type: Pilih HTTP atau HTTPS.

      • URL: Tentukan URL yang menerima event.

      • Body: Tentukan format muatan event. EventBridge dapat mentransformasi event sebelum mendorongnya ke target HTTP. EventBridge mendukung empat format transformasi: Complete Event, Partial Event, Fixed Value, dan Template. Untuk informasi selengkapnya, lihat Event transformation.

      • Network Type:

        • Internet: URL target diakses melalui Internet.

        • VPC: Jika URL target tidak diekspos ke Internet, pilih opsi ini dan tentukan ID VPC, ID vSwitch, dan ID security group.

      Function Compute

      Untuk memicu aksi kustom saat event ECS terjadi, atur tipe layanan menjadi Function Compute. EventBridge mengirimkan event ke fungsi yang ditentukan, dan Anda dapat menerapkan logika kustom di Function Compute.

      • Service Type: Pilih Function Compute.

      • Service: Nama layanan yang Anda buat di Function Compute.

      • Function: Nama fungsi yang Anda buat di Function Compute.

      • Event: Tentukan format muatan event. EventBridge dapat mentransformasi event lalu mendorongnya ke Function Compute. Empat format transformasi didukung: Complete Event, Partial Event, Fixed Value, dan Template. Untuk informasi selengkapnya, lihat Event transformation.

      • Invocation Mode:

        • Synchronous: Function Compute hanya mengembalikan respons sukses setelah fungsi selesai memproses event.

        • Asynchronous: Function Compute mengembalikan respons sukses segera setelah menerima event.

        Untuk informasi selengkapnya, lihat Route events to Function Compute.

      EventBridge

      EventBridge dapat mengagregasikan event ECS dari beberapa akun dan wilayah ke dalam satu event bus. Untuk melakukannya, atur tipe layanan menjadi EventBridge.

      • Destination Type:

        • Same-account Event Bus: Kirimkan event ke event bus lain dalam akun yang sama.

        • Cross-account Event Bus: Kirimkan event ke event bus di akun lain. Pengiriman lintas akun memerlukan otorisasi. Untuk informasi selengkapnya, lihat Route events to EventBridge.

      • Region: Event dapat dirutekan antar-wilayah di dalam Tiongkok daratan, serta antar-wilayah di luar Tiongkok daratan.

      • Event Bus: Nama event bus tujuan.

      • Event: Secara default, event lengkap dikirimkan. Pengaturan ini tidak dapat diubah.

      Di bagian bawah tab Configure Targets, Anda dapat mengonfigurasi kebijakan retry dan dead-letter queue. Untuk informasi selengkapnya, lihat Retries and dead-letter queues.

      Untuk skenario lainnya, lihat Target types.

Langkah 3: Picu event

Topik ini menggunakan jenis event ecs.Instance.StateChange sebagai contoh. Untuk memicu event tersebut, ubah status berjalan instans ECS.

1. Masuk ke Konsol ECS.

2. Di panel navigasi sebelah kiri, pilih Instances & Images > Instance.

3. Di bilah navigasi atas, pilih wilayah tempat sumber daya target berada.

4. Pada kolom Actions instans ECS target, pilih Instance Status dan ubah status instans.

Langkah 4: Lihat hasil pengiriman

1. Periksa apakah ECS telah menghasilkan event.

   EventBridge memungkinkan Anda mengkueri event ECS berdasarkan rentang waktu, jenis event, nama aturan event, atau ID event. ID event di EventBridge sama dengan ID event ECS. Untuk informasi selengkapnya, lihat Query events.

2. Periksa hasil pengiriman langganan event ECS.

   Gunakan ID event yang Anda peroleh pada langkah sebelumnya. Pada kolom Actions yang sesuai dengan ID event tersebut, klik Event Trace untuk melihat jejak pengiriman. Jejak tersebut mencakup target, status, jumlah percobaan, dan waktu. Pada halaman Event Trace, bagian Event Reception menunjukkan bahwa sumber event adalah ECS (acs.ecs), jenis event adalah ecs:Instance:StateChange, dan nama event bus adalah default. Bagian Event Delivery menunjukkan bahwa nama aturan adalah test, target pengiriman adalah URL webhook chatbot DingTalk, status pengiriman adalah Succeeded, latensi pengiriman adalah 258 ms, dan respons pengiriman adalah 200.

Pantau event dan konfigurasi peringatan

Di dasbor pemantauan EventBridge, Anda dapat melihat metrik untuk tugas langganan event ECS yang Anda buat, seperti jumlah panggilan, tingkat keberhasilan pengiriman, dan latensi pengiriman. Anda dapat mengonfigurasi kebijakan peringatan.

Di halaman pemantauan, Anda dapat mengonfigurasi aturan peringatan untuk sumber daya EventBridge. Saat sumber daya memenuhi kondisi aturan peringatan, CloudMonitor secara otomatis mengirimkan pemberitahuan peringatan. Untuk informasi selengkapnya, lihat Create an alert rule.

Retry dan dead-letter queue

Setelah event ditulis ke event bus, EventBridge menjamin bahwa setiap event dikirimkan ke target downstream minimal sekali. Jika penerima downstream tidak tersedia karena downtime, gangguan layanan, atau fluktuasi jaringan, EventBridge menyediakan berbagai cara untuk menangani kegagalan, termasuk kebijakan retry, toleransi kesalahan, dan dead-letter queue. Anda dapat mengonfigurasi opsi ini di Langkah 2: Buat aturan event untuk event ECS guna menjamin pengiriman yang andal.