Node pemantauan kualitas di DataWorks memungkinkan Anda mengonfigurasi aturan untuk memantau kualitas data tabel dalam sumber data Anda dan mendeteksi data kotor. Anda juga dapat menyesuaikan kebijakan penjadwalan untuk menjalankan tugas validasi data secara berkala. Topik ini menjelaskan cara menggunakan node pemantauan kualitas untuk memantau kualitas data.
Latar Belakang
Fitur Kualitas Data di DataWorks membantu Anda mendeteksi perubahan pada data sumber dan mengidentifikasi data kotor yang dihasilkan selama proses ETL (Extract, Transform, and Load). Fitur ini secara otomatis mencegat tugas bermasalah untuk mencegah penyebaran data kotor ke sistem downstream, sehingga menghindari gangguan operasional dan dampak terhadap keputusan bisnis akibat data yang tidak terduga. Selain itu, fitur ini secara signifikan mengurangi waktu troubleshooting dan menghemat sumber daya dengan mencegah eksekusi ulang tugas. Untuk informasi lebih lanjut, lihat Kualitas Data.
Batasan
-
Jenis tabel yang didukung: MaxCompute, E-MapReduce, Hologres, CDH Hive, AnalyticDB for PostgreSQL, AnalyticDB for MySQL, dan StarRocks.
-
Cakupan tabel yang didukung:
-
Anda hanya dapat memantau tabel dalam sumber data yang terikat ke ruang kerja tempat node pemantauan kualitas berada.
-
Setiap node hanya dapat memantau satu tabel, tetapi Anda dapat mengonfigurasi beberapa aturan pemantauan untuknya. Cakupan pemantauan bervariasi tergantung jenis tabel:
-
Untuk tabel non-partisi, seluruh tabel dipantau secara default.
-
Untuk tabel partisi, Anda harus menentukan partisi yang akan dipantau dengan menggunakan ekspresi filter partisi.
CatatanUntuk memantau beberapa tabel, buat beberapa node.
-
-
-
Batasan operasional:
-
Aturan pemantauan kualitas yang dibuat di Data Studio hanya dapat dijalankan, dimodifikasi, dan diterapkan di dalam Data Studio. Meskipun aturan tersebut terlihat di modul Kualitas Data, Anda tidak dapat menjadwalkannya atau mengelolanya dari sana.
-
Jika Anda memodifikasi aturan pemantauan dalam node pemantauan kualitas lalu menerapkan node tersebut, aturan pemantauan yang sebelumnya dihasilkan akan digantikan.
-
Prasyarat
-
Engine komputasi telah diikat ke ruang kerja Anda, dan tabel yang ingin Anda pantau telah dibuat di dalamnya.
Sebelum menjalankan tugas pemantauan kualitas data, Anda harus membuat tabel yang akan diperiksa oleh node pemantauan. Untuk informasi lebih lanjut, lihat Mengikat engine komputasi dan Mengembangkan node.
-
Kelompok sumber daya telah dibuat.
Node pemantauan kualitas hanya dapat dijalankan pada kelompok sumber daya arsitektur tanpa server. Untuk informasi lebih lanjut, lihat Mengelola kelompok sumber daya.
-
(Opsional, untuk Pengguna RAM) Pengguna RAM untuk pengembangan tugas telah ditambahkan ke ruang kerja yang sesuai dan diberikan peran Development atau Workspace Administrator. Peran Workspace Administrator memiliki izin yang luas dan harus diberikan dengan hati-hati. Untuk informasi lebih lanjut tentang menambahkan dan memberikan otorisasi kepada anggota, lihat Menambahkan anggota ke ruang kerja.
Langkah 1: Membuat node pemantauan kualitas
-
Buka halaman Workspaces di Konsol DataWorks. Di bilah navigasi atas, pilih wilayah yang diinginkan. Temukan ruang kerja yang diinginkan dan pilih di kolom Actions.
-
Di panel navigasi kiri, klik
untuk membuka Data Development. Di samping Project Directory, klik
dan pilih . Ikuti petunjuk di layar untuk memasukkan path dan nama node, lalu buat node tersebut.
Langkah 2: Mengonfigurasi aturan pemantauan kualitas
1. Pilih tabel yang akan dipantau
Di halaman editor node pemantauan kualitas, klik Add Table. Di kotak dialog Add Table, pilih tabel yang akan dipantau. Anda dapat menggunakan filter More untuk menemukan tabel lebih cepat.
Jika tabel Anda tidak terdaftar, buka My Data di Data Map.
2. Konfigurasikan cakupan data pemantauan
-
Tabel non-partisi: Seluruh tabel dipantau secara default. Anda dapat melewati langkah ini.
-
Tabel partisi: Anda harus memilih data partisi yang akan dipantau. Anda dapat menggunakan parameter penjadwalan. Klik Preview untuk memverifikasi bahwa ekspresi filter partisi telah diselesaikan dengan benar.
3. Konfigurasikan aturan pemantauan kualitas data
Anda dapat membuat aturan baru atau mengimpor aturan yang sudah ada. Aturan yang dikonfigurasi diaktifkan secara default.
-
Saat membuat aturan di node pemantauan kualitas, Anda dapat menggunakan fitur DataWorks Copilot rule recommendation untuk menghasilkan aturan kualitas secara cerdas berdasarkan informasi tabel Anda. Anda kemudian dapat menerima atau menolak saran tersebut sesuai kebutuhan.
-
DataWorks Copilot sedang dalam pratinjau publik di beberapa wilayah. Jika tidak tersedia di wilayah tempat ruang kerja Anda berada, Anda dapat membuat atau mengimpor aturan secara manual seperti yang dijelaskan dalam topik ini.
-
Buat aturan baru
Klik Create Rule untuk membuat aturan pemantauan kualitas berdasarkan templat atau SQL kustom. Bagian berikut menjelaskan metode-metode tersebut.
Templat bawaan
Anda dapat mengikuti langkah-langkah berikut untuk membuat aturan pemantauan kualitas dengan cepat dari templat aturan.
CatatanAnda juga dapat menemukan templat aturan yang diperlukan di daftar templat bawaan di sebelah kiri dan klik + Use untuk membuatnya.
Klik tab + Built-in Template Rule di sisi kanan kotak dialog. Di panel Built-in Templates di sebelah kiri, perluas kategori templat seperti Table Row Count, temukan templat target, lalu klik + Use. Di formulir di sebelah kanan, konfigurasikan parameter aturan dan klik OK.
Templat kustom
Sebelum menggunakan metode ini, Anda harus terlebih dahulu membuat templat aturan kustom di . Anda kemudian dapat membuat aturan pemantauan kualitas dari templat tersebut. Untuk informasi lebih lanjut, lihat Membuat dan mengelola templat aturan kustom.
Langkah-langkah berikut menunjukkan cara membuat aturan kualitas data dari templat kustom.
CatatanAnda juga dapat menemukan templat aturan yang diperlukan di daftar templat kustom di sebelah kiri dan klik + Use untuk membuatnya.
Di kotak dialog Create Rule, klik tab + Custom Template Rule. Konfigurasikan Rule Name, Rule Template, Quality Dimension, FLAG Parameter, SQL, Comparison Method, dan Monitoring Threshold (termasuk ambang normal dan merah), lalu klik OK.
Custom SQL
Metode ini memungkinkan Anda menentukan logika validasi kualitas data kustom untuk tabel.
Klik tab + Custom SQL di bagian atas. Di formulir di sebelah kanan, konfigurasikan Rule Name, Rule Template (pilih Custom SQL), Quality Dimension, FLAG Parameter, SQL, Comparison Method (pilih Manual Settings atau Intelligent Dynamic Threshold), dan Monitoring Threshold, lalu klik OK.
-
Impor aturan yang sudah ada
Jika aturan pemantauan untuk tabel target sudah ada di modul Data Quality, Anda dapat mengimpornya untuk mengkloning aturan tersebut dengan cepat. Jika tidak ada aturan yang ada, buka Data Quality untuk membuatnya terlebih dahulu. Untuk informasi lebih lanjut, lihat Mengonfigurasi aturan: Berdasarkan tabel (tabel tunggal).
CatatanMetode ini mendukung impor beberapa aturan sekaligus dan memungkinkan konfigurasi aturan pemantauan pada tingkat bidang tabel.
Klik Import Rule. Anda dapat mencari dan memilih aturan yang akan diimpor berdasarkan ID atau nama aturan, templat aturan, atau cakupan terkait (seluruh tabel atau bidang tertentu).
Setelah memilih aturan, klik OK untuk menyelesaikan impor.
Setelah node pemantauan kualitas diterapkan, aturan yang dikandungnya dapat dilihat di modul Data Quality, tetapi operasi pengelolaan seperti memodifikasi atau menghapusnya tidak diizinkan di sana.
4. Konfigurasikan sumber daya waktu proses
Pilih sumber daya waktu proses untuk pemeriksaan aturan kualitas. Pilihan ini menentukan sumber data tempat tugas pemantauan kualitas dijalankan. Secara default, ini adalah sumber data tempat tabel yang dipantau berada.
Jika Anda memilih sumber data lain, pastikan sumber data tersebut memiliki izin akses ke tabel.
Langkah 3: Mengonfigurasi kebijakan penanganan
Di bagian Handling Policy di halaman editor node, Anda dapat mengonfigurasi kebijakan penanganan dan langganan notifikasi untuk pengecualian yang terdeteksi oleh aturan pemantauan kualitas.
Kategori pengecualian
|
Kategori pengecualian |
Deskripsi |
|
Strong rule: Check failed |
|
|
Strong rule: Critical exception |
|
|
Strong rule: Warning exception |
|
|
Weak rule: Check failed |
|
|
Weak rule: Critical exception |
|
|
Weak rule: Warning exception |
Kebijakan penanganan pengecualian
Anda dapat mengonfigurasi kebijakan penanganan untuk pengecualian yang dihasilkan oleh pemeriksaan aturan:
-
Jangan abaikan: Jika kategori pengecualian tertentu terdeteksi (misalnya, aturan kuat memicu pengecualian kritis), Anda dapat mengonfigurasi sistem untuk menghentikan node saat ini dan mengatur statusnya menjadi Gagal.
Catatan-
Setelah node saat ini gagal, node downstream tidak akan dieksekusi. Hal ini memblokir pipeline produksi dan mencegah penyebaran data bermasalah.
-
Anda dapat menambahkan beberapa kategori pengecualian untuk diperiksa.
-
Kebijakan ini biasanya digunakan ketika pengecualian memiliki dampak besar dan perlu memblokir tugas downstream.
-
-
Abaikan: Abaikan pengecualian dan lanjutkan mengeksekusi node downstream.
Metode notifikasi pengecualian
Anda dapat mengonfigurasi cara menerima notifikasi untuk pengecualian (misalnya, melalui email). Saat terjadi pengecualian, platform mengirimkan notifikasi melalui metode yang ditentukan sehingga Anda dapat segera menanganinya.
Platform mendukung berbagai metode notifikasi, yang mungkin berbeda di UI. Perhatikan hal berikut:
-
Notifikasi Email, Email dan SMS, serta Telepon hanya dapat dikirim ke pengguna di bawah akun saat ini. Pastikan alamat email dan nomor telepon penerima telah dikonfigurasi dengan benar. Untuk informasi lebih lanjut, lihat Melihat dan mengatur kontak peringatan.
-
Untuk metode lain, Anda harus memasukkan URL webhook untuk menerima notifikasi. Untuk petunjuk cara mendapatkan URL ini, lihat Mendapatkan URL webhook.
Langkah 4: Mengonfigurasi penjadwalan
Untuk menjalankan tugas node secara berkala, klik Scheduling Settings di sisi kanan halaman editor node dan konfigurasikan properti penjadwalan sesuai kebutuhan bisnis Anda. Untuk informasi lebih lanjut, lihat Mengonfigurasi penjadwalan untuk node.
Langkah 5: Debug tugas
Lakukan operasi debugging berikut sesuai kebutuhan untuk memeriksa apakah tugas berjalan sesuai harapan.
-
(Opsional) Pilih kelompok sumber daya waktu proses dan tetapkan nilai untuk parameter kustom.
-
Di sisi kanan node pemantauan kualitas, klik Run Configuration dan konfigurasikan Resource Group for Scheduling yang akan digunakan untuk debug.
-
Jika tugas Anda menggunakan parameter penjadwalan, Anda dapat menetapkan nilai ke variabel di bagian Script Parameters untuk debugging. Untuk informasi lebih lanjut tentang logika penetapan parameter, lihat Debug tugas.
-
-
Simpan dan jalankan tugas.
Klik ikon
di bilah alat atas untuk menyimpan tugas. Klik ikon
untuk menjalankan tugas.Setelah tugas selesai, Anda dapat melihat hasil eksekusi di bagian bawah halaman editor node. Jika eksekusi gagal, lakukan troubleshooting berdasarkan pesan error.
Langkah 6: Terapkan tugas
Setelah tugas node dikonfigurasi, Anda harus menerapkannya. Setelah diterapkan, node dijalankan secara berkala sesuai konfigurasi penjadwalannya.
Saat Anda menerapkan node pemantauan kualitas, aturan kualitas yang dikonfigurasi di dalamnya juga diterapkan.
-
Di bilah alat atas, klik ikon
untuk save node. -
Di bilah alat atas, klik ikon
untuk deploy node.
Untuk informasi lebih lanjut tentang cara menerapkan node, lihat Menerapkan node dan alur kerja.
Langkah selanjutnya
-
O&M Tugas: Setelah tugas diterapkan, tugas tersebut dijalankan secara berkala berdasarkan konfigurasi penjadwalannya. Anda dapat mengklik O&M di pojok kanan atas halaman editor node untuk membuka Operation Center dan melihat detail penjadwalan dan eksekusi tugas, seperti status eksekusi node dan detail aturan yang dipicu. Untuk informasi lebih lanjut, lihat Mengelola tugas terjadwal.
-
Kualitas Data: Setelah aturan pemantauan kualitas diterapkan, Anda dapat membuka modul Kualitas Data untuk melihat detail aturan. Namun, Anda tidak dapat melakukan operasi pengelolaan seperti memodifikasi atau menghapus aturan di sana. Untuk informasi lebih lanjut, lihat Kualitas Data.