Realtime Compute for Apache Flink：Konfigurasikan aturan peringatan

Peringatan event sistem

Berlangganan event sistem untuk satu atau beberapa pekerjaan.

1. Login ke Konsol Cloud Monitor.

2. Di panel navigasi kiri, pilih Event Center > Event Subscription.

3. Di tab Subscription Policy, klik Create Subscription Policy.

4. Di halaman Create Subscription Policy, konfigurasikan detail langganan. Untuk mengonfigurasi parameter yang tidak tercantum di bawah ini, lihat Kelola langganan event (Direkomendasikan).

   

   • Subscription Type: Pilih System Events.

   • Products: Pilih Flink.

   • Event name: Event yang didukung termasuk JOB_FAILED, ECS.SystemFailure, dan ECS.SystemMaintenance.  

   • Event Content: Isi informasi berikut sesuai kebutuhan.

     • Workspace ID: Masukkan ID ruang kerja, dan aturan peringatan akan berlaku untuk semua pekerjaan di seluruh namespace dalam ruang kerja target. Untuk melihat ID ruang kerja, lihat Bagaimana cara melihat informasi seperti ID ruang kerja?.

     • Nama namespace: Masukkan nama namespace, dan aturan peringatan akan berlaku untuk semua pekerjaan di namespace target.

     • Nama deployment: Masukkan nama deployment pekerjaan, dan aturan peringatan akan berlaku untuk deployment pekerjaan tertentu. Pisahkan beberapa nama menggunakan koma (,). Jika terdapat nama deployment duplikat, gunakan deployment ID.

     • Deployment ID: Masukkan ID deployment pekerjaan, dan aturan peringatan akan berlaku untuk deployment pekerjaan tertentu. Pisahkan beberapa ID menggunakan koma (,). Untuk mendapatkan deployment ID, buka halaman detail deployment Anda.

   Catatan

   Membiarkan Application group, Event Content, atau Event Resources kosong akan menerapkan langganan ke semua ruang kerja dalam akun Anda.

Peringatan event alur kerja

Berlangganan event alur kerja. Untuk detail alur kerja, lihat Kelola alur kerja.

1. Dapatkan ID resource dari tugas alur kerja.

   1. Login ke Konsol Cloud Monitor.

   2. Di panel navigasi kiri, pilih Event Center > System Event.

   3. Di tab Event Monitoring, atur SelectProduct ke Flink, atur SelectEvent Name ke flink:Workflow:TaskStateChange, lalu klik Search.

   4. Filter ID resource tugas alur kerja.

      

      Format ID resource: acs:flink:cn-hangzhou:<AlibabaCloudAccountID>:resourceId/workspaceId/<workspaceId-namespaceId>#workflowDefinitionName/<workflowDefinitionName>#taskDefinitionName/<taskDefinitionName>. Anda juga dapat menggunakan format ini untuk langsung menyusun ID resource tugas alur kerja Anda.

      Parameter	Deskripsi
      <AlibabaCloudAccountID>	ID Akun Alibaba Cloud yang memiliki ruang kerja Flink.
      <workspaceId-namespaceId>	Terdiri dari workspaceId dan namespaceId, digabungkan dengan tanda hubung (-). workspaceId: ID ruang kerja Anda. Untuk informasi selengkapnya, lihat Bagaimana cara melihat informasi tentang ruang kerja, seperti ID ruang kerja?. namespaceId: Nama namespace Anda.
      <workflowDefinitionName>	Nama alur kerja.
      <taskDefinitionName>	Nama tugas alur kerja.

      Catatan

      Perubahan status tugas alur kerja biasanya muncul di Cloud Monitor dengan penundaan beberapa menit.

2. Berlangganan notifikasi event.

   1. Di panel navigasi kiri Konsol Cloud Monitor, pilih Event Center > Event Subscription.

   2. Di tab Subscription Policy, klik Create Subscription Policy.

   3. Di halaman Create Subscription Policy, konfigurasikan kebijakan tersebut. Untuk detail selengkapnya, lihat Kelola langganan event (Direkomendasikan).

      • Subscription Type: Pilih System Events.

      • Products: Pilih Flink.

      • Event name: Pilih flink:Workflow:TaskStateChange.

      • Event Content: Filter berdasarkan status transisi yang diinginkan, misalnya toState: FAILED, toState: SUCCESS, dan fromState: SCHEDULED, toState: RUNNING.

      • Event Resources: Masukkan ID resource yang diperoleh pada langkah sebelumnya. Pisahkan beberapa ID dengan koma (,).

      • Event Type, Event Level, dan Application group: Biarkan parameter ini tidak diatur.

Konfigurasi pekerjaan tunggal (Konsol Pengembangan)

Anda dapat membuat aturan peringatan untuk pekerjaan target dari awal atau menggunakan templat.

1. Buka halaman konfigurasi peringatan.

   1. Login ke Konsol Manajemen Realtime Compute for Apache Flink dan klik Console di kolom Actions ruang kerja Anda.

   2. Di bilah navigasi kiri, pilih O&M > Deployments. Klik deployment pekerjaan Anda.

   3. Pilih tab Alarm.

2. Beralih ke subtab Alarm Rules, lalu pilih Add Rule > Custom Rule.

   Atau, pilih Add Rule > Create Rule by Template.

3. Masukkan informasi aturan peringatan.

   Bagian	Label	Deskripsi
   Rule	Name	Masukkan nama aturan. Nama harus dimulai dengan huruf dan dapat berisi huruf kecil, angka, serta garis bawah (_). Panjang: 3 hingga 64 karakter.
   	Description	Masukkan catatan Anda tentang aturan tersebut.
   	Content	Konfigurasikan kondisi yang memicu peringatan. Realtime Compute for Apache Flink secara berkala membandingkan nilai metrik aktual terhadap ambang batas dan memicu peringatan jika suatu kondisi terpenuhi. Konfigurasikan logika peringatan: Metric: Restart Count in 1 Minute Checkpoint Count in 5 Minutes Emit Delay: Latensi bisnis dari pembuatan data hingga keluaran sumber, dalam detik. Penting Akurasi Emit Delay bergantung pada timestamp yang akurat dari sistem eksternal. Jika sistem eksternal tidak memiliki timestamp atau mencatat timestamp yang salah, Emit Delay akan menjadi tidak akurat dan gagal mencerminkan latensi sebenarnya. Untuk mencerminkan latensi aktual secara lebih akurat, konfigurasikan aturan peringatan untuk metrik gabungan. Untuk detail selengkapnya, lihat Praktik terbaik untuk pemantauan dan peringatan. IN RPS: Catatan masuk per detik. OUT RPS: Catatan keluaran per detik. Source Idle Time: Durasi operator sumber tidak memproses data, dalam milidetik. Job Failed Time Interval: Panjang jangka waktu data historis yang dikueri mundur dari waktu saat ini selama setiap pemeriksaan, dalam menit. Comparator: Mendukung >= dan <=. Thresholds: Nilai yang dibandingkan terhadap metrik. Comparator (>=): Membandingkan nilai metrik maksimum terhadap ambang batas. Peringatan jika max_value >= threshold. Comparator (<=): Membandingkan nilai metrik minimum terhadap ambang batas. Peringatan jika min_value <= threshold. Asumsikan Anda memantau metrik Checkpoint Count in 5 Minutes, dengan interval waktu 10 menit dan ambang batas 2, menggunakan comparator <=. Flink memeriksa setiap menit, mengevaluasi metrik dalam jendela 10 menit. Peringatan dipicu jika jumlah checkpoint berhasil minimum dalam periode 5 menit turun menjadi 2 atau kurang.
   	Effective Time	Jangka waktu ketika aturan peringatan diaktifkan. Default-nya sepanjang hari. Anda dapat membatasi peringatan ke waktu tertentu, seperti jam kerja (pukul 9 pagi hingga 6 sore).
   	Alarm Rate	Interval pengiriman peringatan dalam jumlah menit tertentu. Mendukung 1 menit hingga 1440 menit (24 jam).
   Notification	Notification	Pilih satu atau beberapa metode notifikasi. Opsi meliputi: DingTalk Email SMS Webhook Telepon Pastikan nomor telepon penerima telah diverifikasi; jika tidak, notifikasi tidak akan efektif. Anda dapat mengklik Notification object management di bawah. Jika tag Unverified muncul di kolom Phone untuk kontak target di tab Contacts, klik untuk menyelesaikan verifikasi. Penting Pastikan metode notifikasi yang Anda pilih memiliki objek notifikasi yang sesuai. Untuk DingTalk, artinya menambahkan objek notifikasi robot DingTalk setelah memilih DingTalk sebagai metode.
   	Notification object	Pilih satu atau beberapa objek notifikasi. Klik Notification object management untuk membuat objek notifikasi. Untuk detail selengkapnya, lihat Manajemen ruang kerja dan namespace.
   	Alarm Noise Reduction	Klik Advanced Settings dan aktifkan Alarm Noise Reduction. Saat opsi ini diaktifkan, peringatan hanya dikirim jika ambang batas terpenuhi secara terus-menerus. Ini mencegah peringatan untuk masalah sementara, seperti failover singkat akibat penjadwalan kluster atau penyetelan otomatis.
   	No Data Alarms	Klik Advanced Settings, aktifkan sakelar No Data Alarms, dan tentukan durasinya. Memunculkan peringatan jika tidak ada data pemantauan yang dilaporkan dalam periode waktu yang dipilih. Penyebab umum: Exception JobManager, pekerjaan berhenti, atau kegagalan tautan pelaporan.

4. Klik OK.

   Setelah Anda menyimpan aturan peringatan, aturan tersebut akan diaktifkan secara otomatis dan muncul di daftar aturan peringatan. Anda dapat memilih untuk menghentikan, mengedit, atau menghapusnya.