Mekanisme kontrol alur di Cloud Data Fusion mencegah Anda mengirim terlalu banyak permintaan, yang dapat menyebabkan berjalannya pipeline yang macet atau gagal. Mekanisme ini berlaku untuk memulai permintaan (Launch) pipeline dan tugas berikut di semua edisi Cloud Data Fusion, versi 6.6 dan yang lebih baru:
- Pipeline batch
- Pipeline real-time
- Tugas replikasi
Batas
Untuk mengontrol jumlah permintaan awal yang belum diselesaikan di Cloud Data Fusion, kontrol alur bergantung pada dua nilai minimum:
- Batas peluncuran
- Membatasi jumlah permintaan peluncuran yang dibuat. Jika jumlah permintaan peluncuran yang diterima Cloud Data Fusion yang belum dalam status
Runninglebih besar dari nilai minimum peluncuran (jumlah permintaan peluncuran yang belum berjalan > nilai minimum peluncuran), permintaan akan ditolak. Jumlah ini mencakup pipeline batch, pipeline real-time, dan tugas replikasi. - Ambang batas berjalan
- Membatasi jumlah permintaan peluncuran yang luar biasa dalam sistem. Jika jumlah permintaan peluncuran yang belum diselesaikan yang diterima oleh Cloud Data Fusion yang belum selesai lebih besar dari nilai minimum eksekusi yang ditentukan (jumlah permintaan tertunda yang belum selesai > nilai minimum berjalan), permintaan akan ditolak.
Permintaan yang ditolak
Jika salah satu nilai minimum terpenuhi, setiap permintaan memulai baru akan ditolak. Misalnya,
pipeline batch yang ditolak memiliki status Rejected di log, dan dialog di
UI menjelaskan alasan peluncuran ditolak.
Metrik
Jumlah pipeline yang diluncurkan dan berjalan beserta jumlah pipeline yang ditolak dalam sistem dapat diakses melalui layanan metrik sebagai berikut.
Metrik Launching
Melaporkan jumlah permintaan peluncuran dalam sistem. Artinya, fungsi ini melaporkan
jumlah permintaan peluncuran yang berada dalam status Provisioning atau Starting.
Nama metrik: flowcontrol.launching.count
POST /v3/metrics/query?metric=system.flowcontrol.launching.count
Metrik Running
Melaporkan jumlah pipeline dan tugas yang berjalan di sistem. Nilai minimum run didasarkan pada jumlah nilai metrik Launching dan Running.
Nama metrik: flowcontrol.running.count
POST /v3/metrics/query?metric=system.flowcontrol.running.count
Metrik Rejected
Melaporkan jumlah operasi yang ditolak karena mekanisme kontrol alur.
Nama metrik: program.rejected.runs
POST /v3/metrics/query?metric=system.program.rejected.runs
Langkah selanjutnya
- Untuk contoh penyediaan tag dan penggabungan metrik
Rejecteduntuk pipeline yang berbeda, lihat Microservice Metrik CDAP.