Function Compute:Pemicu Apache RocketMQ yang Dikelola Sendiri

Informasi latar belakang

Saat Anda membuat pemicu di Konsol Function Compute, Function Compute secara otomatis membuat event stream yang sesuai di EventBridge berdasarkan konfigurasi pemicu Anda.

Setelah pemicu dibuat, Anda dapat melihat detailnya di Konsol Function Compute dan sumber daya yang dibuat secara otomatis di Konsol EventBridge. Saat sebuah pesan masuk ke antrian dalam instans Apache RocketMQ Anda, pemicu akan memanggil fungsi Anda. Berdasarkan konfigurasi batching Anda, pemicu mendorong satu atau beberapa event pesan ke fungsi dalam satu batch untuk diproses.

Prasyarat

• EventBridge

  • EventBridge telah diaktifkan dan izin yang diperlukan telah diberikan.

• Function Compute

  • Fungsi telah dibuat.

• Apache RocketMQ

Catatan

Anda dapat menggunakan dokumen berikut untuk segera men-deploy kluster Apache RocketMQ dan mulai mengirim serta menerima pesan.

• Apache RocketMQ 5.0: Quick Start.

• Apache RocketMQ 4.x: Quick Start.

• Kluster Apache RocketMQ yang dikelola sendiri telah dideploy.

• Topik telah dibuat.

• Kelompok konsumen telah dibuat.

Batasan

• Instans Apache RocketMQ yang berperan sebagai sumber event harus dapat diakses melalui Internet publik atau dari VPC Alibaba Cloud.

• Jika instans Apache RocketMQ diakses dari VPC, VPC tersebut harus berada di wilayah yang sama dengan fungsi Anda.

• Anda tidak dapat membuat lebih banyak pemicu Apache RocketMQ setelah jumlah event stream mencapai batas. Untuk informasi lebih lanjut mengenai batasan event stream, lihat Batasan.

Langkah 1: Membuat pemicu Apache RocketMQ yang dikelola sendiri

1. Masuk ke Konsol Function Compute. Di panel navigasi sebelah kiri, pilih Function Management > Functions.

2. Di bilah navigasi atas, pilih wilayah. Pada halaman Functions, klik fungsi yang dituju.

3. Di halaman detail fungsi, klik tab Trigger, lalu klik Create Trigger.

4. Di panel Create Trigger, konfigurasikan parameter, lalu klik OK.

   Parameter	Actions	Example
   Trigger Type	Pilih Self-built Apache RocketMQ.	Self-built Apache RocketMQ
   Name	Masukkan nama kustom untuk pemicu tersebut.	apache-rocketmq-trigger
   Version or Alias	Nilai default adalah LATEST. Untuk membuat pemicu untuk versi atau alias tertentu, Anda harus terlebih dahulu beralih ke versi atau alias tersebut di halaman detail fungsi. Untuk informasi selengkapnya, lihat Manage versions dan Manage aliases.	LATEST
   Endpoint	Masukkan alamat NameServer kluster Apache RocketMQ Anda.	192.168.X.X:9876
   Topic	Pilih topik dalam instans Apache RocketMQ Anda.	testTopic
   Group ID	Pilih ID kelompok konsumen dalam instans Apache RocketMQ Anda.	testGroup
   Filter type	Pilih metode penyaringan pesan. Nilai yang valid: Tag: Menyaring pesan berdasarkan tag. SQL: Menyaring pesan menggunakan ekspresi SQL. Hal ini memungkinkan Anda mencocokkan properti dan nilai pesan.	Tag
   Filter	Setelah Anda memilih Filter type, tentukan ekspresi filter yang sesuai.	TagA
   Authentication Mode	Pilih mode otentikasi. Hanya ACL yang didukung.	ACL
   Username	Jika Anda mengatur Authentication Mode ke ACL, masukkan username untuk otentikasi.	admin
   Password	Jika Anda mengatur Authentication Mode ke ACL, masukkan password untuk otentikasi.	******
   Consumer Offset	Pilih titik awal untuk konsumsi pesan. EventBridge akan menarik pesan mulai dari offset ini. Nilai yang valid: Latest Offset: Mulai mengonsumsi dari offset terbaru. Earliest Offset: Mulai mengonsumsi dari offset paling awal. Timestamp: Mulai mengonsumsi dari titik waktu tertentu.	Latest offset
   Networking	Pilih jenis jaringan untuk perutean pesan. Nilai yang valid: Internet: Akses kluster Apache RocketMQ melalui internet publik. VPC: Akses kluster Apache RocketMQ melalui VPC Alibaba Cloud. Anda harus memilih VPC, vSwitch, dan Security Group.	Public network
   Invocation Method	Pilih metode pemanggilan. Nilai yang valid: Sync Invocation: Ini adalah metode default. Sebuah event memicu fungsi. Function Compute menunggu hingga pemanggilan selesai, lalu mengembalikan hasil eksekusi. Untuk informasi selengkapnya, lihat Synchronous invocations. Async Invocation: Metode ini cocok untuk fungsi berdurasi panjang. Setelah sebuah event memicu fungsi, Function Compute langsung mengembalikan respons. Metode ini menjamin fungsi dieksekusi setidaknya sekali, tetapi tidak mengembalikan hasil eksekusi. Untuk informasi selengkapnya, lihat Asynchronous invocation overview.	Synchronous invocation
   Trigger State	Tentukan apakah pemicu diaktifkan segera setelah dibuat. Opsi ini diaktifkan secara default.	Enable trigger

   Untuk informasi tentang pengaturan lanjutan, seperti konfigurasi push, kebijakan retry, dan dead-letter queue, lihat Advanced features of triggers.

   Setelah pemicu dibuat, pemicu tersebut akan muncul di tab Triggers. Untuk mengubah atau menghapus pemicu, lihat Manage triggers.

Langkah 2: Mengonfigurasi event pengujian

Sumber event Apache RocketMQ yang dikelola sendiri meneruskan event ke fungsi sebagai parameter input. Anda dapat secara manual meneruskan event ke fungsi untuk mensimulasikan pemicuan event.

1. Di tab Code pada halaman detail fungsi, klik ikon di samping Test Function dan pilih Configure Test Parameters dari daftar drop-down.

2. Di panel Configure Test Parameters, pilih Create New Test Event atau Modify Existing Test Event. Masukkan nama event, berikan konten event, lalu klik OK.

   event memiliki format berikut.

   [
     {
       "msgId": "7F0000010BDD2A84AEE70DA49B57****",
       "topic": "testTopic",
       "systemProperties": {
         "UNIQ_KEY": "7F0000010BDD2A84AEE70DA49B57****",
         "CLUSTER": "DefaultCluster",
         "MIN_OFFSET": "0",
         "TAGS": "TagA",
         "MAX_OFFSET": "128"
       },
       "userProperties": {},
       "body": "Hello RocketMQ"
     }
   ]

   Parameter pada bidang event dijelaskan dalam tabel berikut.

   Parameter	Tipe	Contoh	Deskripsi
   msgId	String	7F0000010BDD2A84AEE70DA49B57****	ID pesan dari Apache RocketMQ.
   topic	String	testTopic	Nama topik.
   systemProperties	Map		Properti sistem.
   UNIQ_KEY	String	7F0000010BDD2A84AEE70DA49B57****	Kunci unik dari pesan.
   CLUSTER	String	DefaultCluster	Nama kluster Apache RocketMQ.
   MIN_OFFSET	Integer	0	Offset minimum.
   MAX_OFFSET	Integer	128	Offset maksimum.
   TAGS	String	TagA	Tag filter.
   userProperties	Map	None	Properti yang ditentukan pengguna.
   body	String	Hello RocketMQ	Isi pesan.

Langkah 3: Menulis dan menguji kode fungsi

Setelah Anda membuat pemicu, Anda dapat menulis dan menguji kode fungsi Anda. Dalam skenario dunia nyata, pemicu secara otomatis memanggil fungsi saat Apache RocketMQ menerima pesan.

1. Di halaman detail fungsi, klik tab Code. Tulis kode Anda di editor, lalu klik Deploy.

   Topik ini menggunakan Node.js sebagai contoh. Berikut adalah contoh kode.

   'use strict';
   /*
   Untuk mengaktifkan fitur initializer,
   implementasikan fungsi inisialisasi sebagai berikut:
   exports.initializer = (context, callback) => {
     console.log('initializing');
     callback(null, '');
   };
   */
   exports.handler = (event, context, callback) => {
     console.log("event: %s", event);
     // Parsing parameter event dan proses event.
     callback(null, 'return result');
   }

2. Klik Test Function.

Informasi lebih lanjut

Untuk mengubah atau menghapus pemicu, lihat Manage triggers.