Fitur langganan pesan real-time OpenEvent - DataWorks

Modul OpenEvent memungkinkan Anda berlangganan pesan acara. Anda dapat menerima notifikasi tentang berbagai perubahan di DataWorks dan menanggapi acara tersebut sesuai dengan konfigurasi Anda. Sebagai contoh, Anda dapat berlangganan peristiwa perubahan tabel untuk menerima notifikasi real-time tentang perubahan tabel inti. Anda juga dapat berlangganan peristiwa perubahan tugas untuk mengimplementasikan pemantauan data kustom pada dasbor yang menampilkan status sinkronisasi tugas secara real-time. Topik ini menjelaskan jenis-jenis acara yang dapat dilanggan menggunakan OpenEvent serta prosedur konfigurasi langganan.

Prasyarat

Edition Enterprise DataWorks harus diaktifkan di wilayah yang didukung. Modul OpenEvent tersedia untuk pengguna Edition Enterprise DataWorks di wilayah berikut: Tiongkok (Beijing), Tiongkok (Hangzhou), Tiongkok (Shanghai), Tiongkok (Zhangjiakou), Tiongkok (Shenzhen), Tiongkok (Chengdu), AS (Silicon Valley), AS (Virginia), Jerman (Frankfurt), Jepang (Tokyo), Tiongkok (Hong Kong), dan Singapura.
EventBridge harus diaktifkan. Modul OpenEvent menggunakan EventBridge untuk berlangganan dan mengonsumsi pesan. Untuk informasi lebih lanjut, lihat Apa itu EventBridge?

Deskripsi izin

The Open Platform administrator dan tenant administrator memiliki izin baca dan tulis pada developer backend. Peran tingkat penyewa lainnya dan peran tingkat ruang kerja hanya memiliki izin baca-saja pada backend pengembang. Untuk informasi lebih lanjut, lihat Kelola izin pada layanan tingkat global.
Hanya akun Alibaba Cloud atau pengguna RAM dengan kebijakan AliyunDataWorksFullAccess yang dapat digunakan untuk mengonfigurasi pengaturan di halaman konsol DataWorks. Untuk informasi lebih lanjut, lihat Kelola izin pada layanan DataWorks dan entitas di konsol DataWorks menggunakan kebijakan RAM.

Informasi latar belakang

DataWorks memungkinkan Anda berlangganan pesan peristiwa perubahan status dalam proses utama DataWorks dan mendorong pesan tersebut ke modul OpenEvent dari DataWorks Open Platform. Anda dapat menggunakan modul OpenEvent untuk mendorong pesan acara di ruang kerja dan menggunakan EventBridge untuk memfilter dan mengonsumsi pesan.

Konsep

Acara DataWorks diklasifikasikan menjadi acara reguler dan acara titik ekstensi berdasarkan apakah proses operasi terkait dengan suatu acara di DataWorks dapat diblokir.

Regular events: Anda dapat mengembangkan program lokal untuk menerima pesan dari jenis acara ini dan mengonfigurasi tanggapan kustom terhadap pesan acara sesuai dengan kebutuhan bisnis Anda.
Extension point events: Jenis acara ini memiliki karakteristik dan kemampuan acara reguler. Selain itu, jenis acara ini memungkinkan Anda mendaftarkan program lokal sebagai ekstensi DataWorks untuk memproses pesan acara yang dihasilkan oleh operasi yang Anda lakukan di DataWorks berdasarkan logika pemrosesan kustom, seperti memblokir operasi.

Acara DataWorks juga diklasifikasikan menjadi acara tingkat ruang kerja dan acara tingkat penyewa berdasarkan ruang lingkup efektif acara.

Acara tingkat ruang kerja: Acara yang dihasilkan dalam layanan tingkat ruang kerja. Contohnya, acara yang dihasilkan saat node dijalankan di DataStudio dan acara yang dihasilkan saat status instance diubah di Pusat Operasi adalah acara tingkat ruang kerja.
Acara tingkat penyewa: Acara yang dihasilkan dalam layanan tingkat penyewa. Contohnya, acara yang dihasilkan ketika pengguna menghapus ruang kerja di konsol DataWorks adalah acara tingkat penyewa. Tabel berikut menjelaskan acara yang didukung oleh setiap layanan DataWorks, apakah suatu acara merupakan acara reguler atau acara titik ekstensi, serta format pesan suatu acara.

Jenis acara yang didukung

Tabel berikut mencantumkan acara titik ekstensi dan acara reguler yang didukung di tingkat ruang kerja dan tingkat penyewa.

Acara tingkat ruang kerja

DataStudio

Untuk informasi tentang format pesan acara di DataStudio, lihat bagian Daftar acara DataStudio dalam topik "Referensi pengembangan: Daftar acara dan format pesan acara".

Kategori acara	Acara	Acara reguler	Acara titik ekstensi	Contoh (operasi pembuatan acara)
Perubahan node acara	Buat node			Buat node dan deploy node ke lingkungan produksi.
Perubahan node acara	Perbarui node			Ubah node di lingkungan pengembangan. Ubah node dan deploy node ke lingkungan produksi.
Perubahan file acara Node Sumber daya Fungsi	Hapus file			Hapus file di lingkungan pengembangan. Pindahkan file yang dihapus ke tempat sampah.
	Komit file			Komit node, sumber daya, atau fungsi di DataStudio.
	Deploy file			Deploy node, sumber daya, atau fungsi di DataStudio.
	Jalankan kode node			Jalankan kode node di DataStudio.
Perubahan tabel acara	Komit tabel ke lingkungan pengembangan			Komit tabel di halaman Tabel Ruang Kerja DataStudio.
Perubahan tabel acara	Deploy tabel ke lingkungan produksi			Deploy tabel di panel Tabel Ruang Kerja DataStudio. Catatan Anda hanya dapat mendeploy tabel di panel Tabel Ruang Kerja dalam ruang kerja dalam mode standar. Oleh karena itu, acara penyebaran tabel hanya dapat dihasilkan dalam ruang kerja yang berada dalam mode standar.

Data Integration

Untuk informasi tentang format pesan acara di Data Integration, lihat bagian Acara Data Integration dalam topik "Referensi pengembangan: Daftar acara dan format pesan acara".

Kategori acara	Acara	Acara reguler	Acara titik ekstensi	Contoh (operasi pembuatan acara)
Perubahan node acara	Acara pra-Di-Job berjalan			Mulai tugas real-time di Data Integration.
Perubahan node acara	Acara pra-Di-Job batch berjalan			Mulai batch tugas real-time di Data Integration.

Pusat Operasi

Untuk informasi tentang format pesan acara di Pusat Operasi, lihat bagian Daftar acara Pusat Operasi dalam topik "Referensi pengembangan: Daftar acara dan format pesan acara".

Kategori acara	Acara	Acara reguler	Acara titik ekstensi	Contoh (operasi pembuatan acara)
Perubahan node	Hapus node			Deploy operasi penghapusan ke lingkungan produksi untuk mengundeploy node di lingkungan produksi. Hapus node dari tempat sampah.
	Undeploy node			Undeploy node pemicu otomatis di lingkungan produksi. Catatan Operasi ini menghapus node di DataStudio dan memindahkan node ke tempat sampah.
	Bekukan node			Bekukan node di halaman Node Pemicu Otomatis Pusat Operasi.
	Buka pembekuan node			Buka pembekuan node di halaman Node Pemicu Otomatis Pusat Operasi.
Pengisian ulang data untuk node	Isi ulang data untuk node			Isi ulang data untuk node pemicu otomatis. Isi ulang data untuk node pemicu otomatis dan node turunan dari node tersebut. Isi ulang data untuk sejumlah besar node. Isi ulang data dalam mode lanjutan.
Perubahan status node	Ubah status node pemicu otomatis			Acara perubahan status tugas penjadwalan dapat dihasilkan dalam skenario berikut: Tugas penjadwalan dikirim ke Data Quality untuk pemeriksaan kualitas data. Tugas penjadwalan diperiksa berdasarkan kondisi cabang. Tugas penjadwalan dipicu sesuai jadwal, dipicu secara manual, atau dipicu oleh suatu acara. Status tugas berubah dari Waiting for Resources menjadi Running. Tugas penjadwalan selesai dijalankan baik berhasil maupun gagal. Status tugas berubah dari Running menjadi Successful. Tugas penjadwalan dijalankan ulang setelah tugas penjadwalan gagal dijalankan. Status tugas berubah dari Run Failed menjadi Running. Tugas penjadwalan dijadwalkan untuk dijalankan. Status tugas berubah menjadi Menunggu Waktu Penjadwalan. Waktu penjadwalan ditentukan oleh parameter DueTime atau cycleTime.
Perubahan instansi acara	Bekukan instance			Ketika Anda melakukan salah satu operasi berikut pada instansi yang dipicu otomatis di Pusat Operasi, acara yang sesuai akan dipicu: Bekukan instance. Buka pembekuan instansi. Hentikan instance. Jalankan ulang instance. Atur status instansi menjadi berhasil. Hapus instance leluhur tertentu dari instance.
	Buka pembekuan instance
	Hentikan instance
	Jalankan ulang instance Jalankan ulang instance Jalankan ulang instance turunan dari instance
	Atur status instansi menjadi berhasil
	Hapus instance leluhur tertentu dari instance
	Acara pra-instansi dibekukan			Ketika Anda melakukan salah satu operasi berikut pada instansi yang dipicu otomatis di Pusat Operasi, acara yang sesuai akan dipicu. Bekukan instansi. Buka pembekuan instansi. Jalankan ulang instansi. Atur status instansi menjadi berhasil. Hentikan instansi.
	Acara pra-instansi dibuka pembekuan
	Acara pra-instansi dijalankan ulang
	Acara pra-set instansi berhasil
	Pra-peristiwa Penghentian Instans
	Hapus instansi kedaluwarsa
Perubahan status alur kerja	Ubah status alur kerja Isi ulang data untuk instance Jalankan alur kerja pemicu manual			Isi ulang data untuk node. Jalankan alur kerja pemicu manual.
Pemantauan dan peringatan	Pantau objek dan kirim peringatan			Peringatan baseline: Jika node dalam baseline tidak selesai dijalankan sebelum waktu penyelesaian yang diperkirakan, peringatan akan dipicu. Peringatan berbasis acara: Jika node dalam baseline gagal dijalankan, peringatan akan dipicu. Peringatan berbasis aturan: Jika Anda membuat aturan peringatan untuk node terisolasi, peringatan akan dipicu setelah node terisolasi diidentifikasi dalam alur kerja.

Pusat Keamanan

Untuk informasi tentang format pesan acara di Pusat Keamanan, lihat bagian Daftar acara Pusat Keamanan dalam topik "Referensi pengembangan: Daftar acara dan format pesan acara".

Kategori acara	Acara	Acara reguler	Peristiwa Titik Ekstensi	Contoh (operasi pembuatan acara)
Pembuatan atau pemrosesan pesanan permintaan	Acara pra-pesanan persetujuan dibuat			Buat pesanan permintaan untuk function, table, atau resource di tab Permission Application pada halaman Data Access Control di Security Center.
Pembuatan atau pemrosesan pesanan permintaan	Selesaikan pesanan permintaan			Proses pesanan permintaan untuk tabel, sumber daya, atau fungsi di tab Permission Application Processing pada halaman Data Access Control di Security Center.
Perubahan izin tabel	Minta izin pada tabel			Ajukan permintaan izin baca, tulis, dan modifikasi pada tabel tertentu berdasarkan kebutuhan bisnis.

Kualitas Data

Untuk informasi tentang format pesan acara di Kualitas Data, lihat bagian Daftar acara Integrasi Data dalam topik "Referensi pengembangan: Daftar acara dan format pesan acara".

Kategori acara	Acara	Acara reguler	Titik Ekstensi Acara	Contoh (operasi pembuatan acara)
Pemeriksaan kualitas data	Berikan umpan balik pada hasil pemeriksaan kualitas data			Berikan umpan balik pada hasil pemeriksaan di Kualitas Data. Sebagai contoh, Anda mengaktifkan aturan pemantauan yang digunakan untuk memeriksa apakah jumlah baris dalam tabel melebihi 0 untuk tabel tertentu di Kualitas Data. Setelah aturan dipicu dan pemeriksaan selesai, pengguna dapat memberikan umpan balik mereka pada hasil pemeriksaan. Setelah umpan balik diberikan, sistem mengirimkan umpan balik yang berisi informasi seperti ID aturan pemantauan dan isi umpan balik kepada pelanggan.
Pemeriksaan kualitas data	Laporkan bahwa pemeriksaan kualitas data selesai			Kirim hasil pemeriksaan kualitas data, termasuk apakah pemeriksaan berhasil dan informasi pengambilan sampel. Sebagai contoh, Anda mengaktifkan aturan pemantauan yang digunakan untuk memeriksa apakah jumlah baris dalam tabel melebihi 0 untuk tabel tertentu di Kualitas Data. Jika aturan dipicu dan pemeriksaan selesai, sistem mengirimkan hasil pemeriksaan kepada pelanggan. Hasil pemeriksaan menunjukkan apakah data lulus pemeriksaan kualitas dan berisi sampel yang digunakan.
Acara pra-aturan kualitas data	Acara pra-aturan kualitas data batch create			Sebagai contoh, di modul Data Quality, buka halaman Configure Rules > Configure by Table dan buka halaman detail tabel tertentu. Di tab Rule Management, melakukan operasi berikut memicu acara pra-yang sesuai: Buat beberapa aturan pemantauan kualitas data. Ubah beberapa aturan pemantauan kualitas data. Hapus beberapa aturan pemantauan kualitas data. Ubah satu aturan pemantauan kualitas data.
	Acara pra-aturan kualitas data batch update
	Acara pra-aturan kualitas data batch delete
	Acara pra-aturan kualitas data update
Acara pra-tugas evaluasi kualitas data	Acara pra-tugas evaluasi kualitas data create			Sebagai contoh, di modul Data Quality, buka halaman Rule Configuration > Configure by Table dan buka halaman detail tabel tertentu. Di tab Monitor, melakukan operasi berikut memicu acara pra-yang sesuai: Buat monitor kualitas data. Ubah monitor kualitas data. Klon monitor kualitas data. Hapus batch monitor kualitas data.
	Acara pra-tugas evaluasi kualitas data update
	Acara pra-tugas evaluasi kualitas data clone
	Acara pra-tugas evaluasi kualitas data batch delete
Acara pra-notifikasi tugas evaluasi kualitas data	Acara pra-notifikasi tugas evaluasi kualitas data create			Sebagai contoh, di modul Data Quality, buka halaman Rule Configuration > Configure by Table dan buka halaman detail tabel tertentu. Di tab Monitor, berlangganan peringatan untuk monitor kualitas data tertentu.
	Acara pra-notifikasi tugas evaluasi kualitas data update			Sebagai contoh, di modul Data Quality, buka halaman Rule Configuration > Configure by Table dan buka halaman detail tabel tertentu. Di tab Monitor, ubah pengaturan langganan peringatan monitor kualitas data tertentu.
	Acara pra-notifikasi tugas evaluasi kualitas data delete			Sebagai contoh, di modul Data Quality, buka halaman Rule Configuration > Configure by Table dan buka halaman detail tabel tertentu. Di tab Monitor, hapus langganan peringatan monitor kualitas data tertentu.

Acara tingkat penyewa

DataWorks console

Untuk informasi tentang format pesan acara di konsol DataWorks, lihat bagian Daftar acara konsol manajemen dalam topik "Referensi pengembangan: Daftar acara dan format pesan acara".

Kategori acara

Acara

Acara biasa

Acara titik ekstensi

Contoh (operasi pembuatan acara)

Penghapusan ruang kerja

Hapus ruang kerja (pra-acara)

Pra-acara penghapusan ruang kerja dihasilkan sebelum pengguna menghapus ruang kerja di halaman Ruang Kerja. pre-event for workspace deletion dapat memicu ekstensi terkait untuk memblokir proses.

Hapus ruang kerja (pasca-acara)

Unggah dan Unduh

Untuk informasi tentang format pesan acara di Unggah dan Unduh, lihat bagian Daftar acara unggah dan unduh dalam topik "Referensi pengembangan: Daftar acara dan format pesan acara".

Kategori acara	Acara	Acara biasa	Acara titik ekstensi	Contoh (operasi pembuatan acara)
Unduh dan unggah data	Unduh data (pra-acara) (pembuatan file)			Acara unduh atau unggah data dihasilkan saat Anda mengunduh atau mengunggah data di Unggah dan Unduh. Sebelum Anda mengunduh data, pre-event for data download dihasilkan untuk mendapatkan informasi tentang operasi unduhan.
	Unduh data (pra-acara) (unduh file)
	Unggah data (pra-acara)

Manfaat aplikasi

Modul OpenEvent menyediakan manfaat berikut:

Biaya O&M rendah:
Setelah mengaktifkan fitur langganan pesan di DataWorks Open Platform, Anda dapat dengan mudah berlangganan acara DataWorks.
Peningkatan efisiensi penerbitan dan penerimaan pesan:
Anda hanya perlu mengonfigurasi parameter untuk langganan pesan dan membuat persiapan untuk pengembangan SDK, sehingga mengurangi dan menyederhanakan operasi manual.
Pemenuhan berbagai kebutuhan:
Anda dapat berlangganan berbagai jenis acara DataWorks, memungkinkan Anda mengidentifikasi perubahan penting di DataWorks dan meresponsnya secepat mungkin.