EventBridge adalah layanan data event tanpa server (serverless) yang sepenuhnya dikelola oleh Alibaba Cloud dan berfungsi sebagai pusat integrasi serta pemrosesan data di era AI-native. EventBridge menghubungkan komponen aplikasi melalui event untuk membangun arsitektur berbasis event (EDA) yang longgar terikat (loosely coupled) dan skalabel.
Topik ini menjelaskan resource inti, konsep dasar, dan skenario khas penggunaan EventBridge.
Arsitektur berbasis event
Arsitektur berbasis event adalah pola desain perangkat lunak di mana komponen sistem berkolaborasi dengan menerbitkan dan merespons event, bukan melalui panggilan langsung satu sama lain. Pola ini memberikan penguraian keterkaitan (loose coupling) dan skalabilitas tinggi, sehingga ideal untuk skenario seperti orkestrasi layanan mikro, pemrosesan data real-time, dan O&M otomatis.
Untuk informasi latar belakang lebih lanjut, lihat:
Resource inti
EventBridge didasarkan pada standar CloudEvents 1.0 dan menghubungkan layanan Alibaba Cloud, aplikasi kustom, serta platform SaaS pihak ketiga. Dengan kemampuan bawaan untuk filtering, transformasi, dan routing, EventBridge mengirimkan event dari sumber ke sistem target tanpa memerlukan kode integrasi.
EventBridge menyediakan tiga jenis resource inti untuk berbagai skenario pemrosesan event:
Dimensi | Event bus | Event stream | EventHouse |
Temukan | Routing dan distribusi event | Pengumpulan dan transmisi data masif secara kontinu | Penyimpanan persisten dan analisis query event |
Pola routing | N:M (many-to-many) | 1:1 (one-to-one) | — |
Kemampuan inti | Filtering, transformasi, dan pengiriman ke multi-target | Throughput tinggi, latensi rendah, dan replay konsumsi | Kueri SQL instan dan penyimpanan berbiaya rendah |
Skenario khas | Penguraian keterkaitan layanan mikro, integrasi SaaS, dan O&M otomatis | Pengumpulan log, agregasi data IoT, dan ETL real-time | Audit event, analisis akar masalah, dan laporan BI |
Event bus
Event bus adalah resource routing inti EventBridge yang menerima event dan mendistribusikannya ke satu atau beberapa target.
Berdasarkan standar CloudEvents 1.0, event bus menerima event dari layanan Alibaba Cloud, aplikasi kustom, atau aplikasi SaaS. Dengan mengonfigurasi aturan event, event dapat difilter dan ditransformasi sebelum dikirimkan ke layanan target seperti Function Compute, ApsaraMQ for RocketMQ, dan DingTalk.
Kemampuan utama
Filtering konten: Memfilter event berdasarkan kontennya menggunakan aturan event.
Transformasi event: Mengubah struktur event selama routing agar sesuai dengan format data yang dibutuhkan oleh sistem target.
Pengiriman multi-target: Memicu beberapa layanan downstream untuk memproses satu event dari satu publikasi.
Skenario khas
Penguraian keterkaitan layanan mikro: Layanan pesanan menerbitkan event "Order Created". Layanan inventaris, logistik, dan reward masing-masing berlangganan event tersebut secara independen tanpa saling mengetahui keberadaan satu sama lain.
Integrasi SaaS: Ketika informasi pelanggan diperbarui di Salesforce, informasi tersebut secara otomatis disinkronkan ke sistem CRM internal.
O&M otomatis: Saat Cloud Monitor mendeteksi event kegagalan instans, sistem secara otomatis memicu skrip O&M atau mengirimkan pemberitahuan peringatan.
Event stream
Event stream adalah resource transmisi data ber-throughput tinggi dalam EventBridge yang bertanggung jawab atas pengumpulan kontinu dan pemrosesan real-time sejumlah besar data.
Berbeda dengan routing many-to-many pada event bus, event stream menyediakan layanan transmisi data one-to-one (1:1) yang dirancang untuk skenario data ber-throughput tinggi dan berurutan. Resource ini cocok untuk memproses aliran data kontinu seperti log, metrik pemantauan, dan data perilaku pengguna.
Kemampuan utama
Throughput tinggi dan latensi rendah: Mendukung penulisan dan pembacaan data hingga jutaan transaksi per detik (TPS).
Replay konsumsi: Mendukung pengambilan data dari titik waktu tertentu di masa lalu untuk diproses ulang.
Skenario khas
Gudang data real-time: Mengumpulkan log biner (binlogs) dari database bisnis atau log aplikasi secara real-time, memprosesnya dengan Flink, lalu menuliskannya ke gudang data.
Pengumpulan data IoT: Mengagregasi data status yang dilaporkan oleh sejumlah besar perangkat melalui event stream, lalu mendistribusikannya ke sistem analitik downstream.
Analis aliran klik (clickstream): Menangkap data perilaku pengguna di situs web atau aplikasi secara real-time untuk digunakan oleh sistem rekomendasi.
Event house
Event house adalah resource penyimpanan dan analisis event terstruktur dalam EventBridge. Saat diaktifkan, semua data event yang melewati EventBridge disimpan secara persisten dan dapat dikueri serta dianalisis kapan saja.
Event house menggunakan arsitektur penyimpanan bertingkat berbasis kolom untuk mengurangi biaya penyimpanan sekaligus memastikan performa kueri. Selain menyimpan riwayat event untuk pelacakan dan disaster recovery, resource ini mendukung kueri SQL instan guna mengubah data event menjadi wawasan bisnis.
Kemampuan utama
Kueri SQL instan: Memungkinkan Anda menjalankan kueri SQL standar langsung pada event historis tanpa memindahkan data ke gudang data. Kemampuan ini mendukung agregasi multidimensi, filtering, dan analisis.
Penyimpanan lakehouse berbiaya rendah: Menggunakan arsitektur penyimpanan bertingkat yang cocok untuk retensi jangka panjang data event dalam jumlah besar.
Skenario khas
O&M cerdas dan analisis akar masalah: Saat sistem mengalami kegagalan, Anda dapat menggunakan SQL untuk dengan cepat mengambil rantai event anomali dalam jendela waktu kegagalan guna mengidentifikasi akar masalahnya.
Laporan intelijen bisnis: Anda dapat menghubungkan alat seperti Quick BI ke event house untuk menghasilkan laporan bisnis real-time berdasarkan aliran event.
Audit dan kepatuhan event: Anda dapat menyimpan catatan event bisnis dalam jangka panjang untuk memenuhi persyaratan audit dan kepatuhan.
Cara memilih
Pilih resource yang sesuai berdasarkan skenario Anda:
Untuk merutekan event dari banyak sumber ke banyak target, gunakan event bus. Misalnya, event pesanan perlu secara simultan memberi tahu sistem inventaris, logistik, dan reward.
Untuk membangun pipa data ber-throughput tinggi antara dua sistem, gunakan event stream. Misalnya, menyinkronkan log perubahan database secara kontinu ke sistem analitik downstream.
Untuk menyimpan dan mengkueri data event historis, gunakan event house. Misalnya, menganalisis distribusi semua event pembayaran gagal selama sebulan terakhir.
Catatan: Ketiga resource ini dapat digunakan bersamaan. Misalnya, event bus dapat menerima dan merutekan event, event stream dapat menyediakan saluran ber-throughput tinggi, dan event house dapat menyimpan data historis untuk kueri dan analisis.
Skenario AI
Mesin filtering dan transformasi bawaan pada EventBridge melakukan pembersihan lalu lintas (traffic scrubbing) dan peningkatan fitur secara real-time sebelum data memasuki model AI. EventBridge juga mendukung perutean event yang telah diproses ke platform pembelajaran mesin atau database vektor.
Skenario | Resource yang digunakan | Deskripsi |
Pemicu inferensi AI real-time | Event bus | Saat OSS menerima event unggah gambar, sistem secara otomatis memicu Function Compute untuk memanggil model AI guna melakukan pengenalan. |
Pipa data pelatihan AI | Event stream | Secara kontinu mengumpulkan data perilaku pengguna sebagai sumber input real-time untuk penyempurnaan model. |
Konteks agen AI | Event Store | Berfungsi sebagai sumber pengetahuan untuk Generasi yang Diperkaya dengan Pengambilan Data (RAG), memungkinkan agen AI mengkueri event bisnis historis. |
Istilah
Konsep | Deskripsi |
Event | Catatan data mengenai perubahan status sistem. Ini merupakan unit dasar yang diproses oleh EventBridge. |
Event source | Sumber event. Bertanggung jawab untuk menghasilkan event. Event source dapat berupa layanan Alibaba Cloud, aplikasi kustom, atau platform SaaS. |
Event target | Titik akhir pemrosesan event. Bertanggung jawab untuk mengonsumsi event. Event target dapat berupa Function Compute, ApsaraMQ for RocketMQ, titik akhir HTTP, atau layanan lainnya. |
Event bus | Pusat routing event. Bertanggung jawab untuk menerima, memfilter, mentransformasi, dan mendistribusikan event. |
Event rule | Menentukan kondisi untuk mencocokkan event dan target pengirimannya. Saat event yang sesuai terjadi, event tersebut dirutekan ke event target terkait. |
Untuk informasi lebih lanjut, lihat Istilah.
Manfaat
Penagihan
Untuk informasi lebih lanjut, lihat Ikhtisar penagihan.