Realtime Compute for Apache Flink:Konfigurasikan pemantauan dan peringatan

Peringatan event pekerjaan

Berlangganan peringatan event sistem untuk pekerjaan dengan mengonfigurasi kondisi. Konfigurasi batch untuk peringatan event didukung.

1. Masuk ke Konsol Cloud Monitor.

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

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

4. Di halaman Create Subscription Policy, konfigurasikan parameter. Untuk informasi selengkapnya mengenai parameter tersebut, lihat Mengelola langganan event (direkomendasikan).

   • Subscription Type: System Event.

   • Product: Pilih Realtime Compute for Apache Flink.

   • Event Name: Mendukung event Job Run Failed (tidak didukung saat menggunakan layanan pemantauan ARMS), Post-mortem Processing for ECS Downtime, dan Impact of Proactive O&M on ECS.

   • Event Content: Anda dapat menentukan pekerjaan atau mengonfigurasi peringatan batch dengan memasukkan informasi Flink berikut dalam konten event.

     • Workspace ID: Konfigurasikan peringatan event untuk semua pekerjaan di semua namespace di bawah ruang kerja target. Untuk melihat Workspace ID, lihat Bagaimana cara melihat informasi seperti ID ruang kerja?.

     • Namespace Name: Konfigurasikan peringatan event untuk semua pekerjaan di namespace target.

     • Deployment Job Name: Konfigurasikan peringatan event untuk pekerjaan tertentu. Pisahkan beberapa nama pekerjaan dengan koma (,). Jika ada pekerjaan dengan nama yang sama di bawah akun Anda, gunakan DeploymentID sebagai gantinya.

     • DeploymentID: Konfigurasikan peringatan event untuk pekerjaan tertentu. Pisahkan beberapa ID dengan koma (,). Anda dapat menemukan ID ini pada tab Configuration halaman pekerjaan Flink sebagai deployment ID.

   Catatan

   Jika Anda tidak mengatur Application Group, Message, atau Event Resource, langganan berlaku untuk semua ruang kerja dalam akun Anda.

Peringatan event alur kerja

Berlangganan peringatan event sistem untuk alur kerja Flink dengan mengonfigurasi kondisi. Konfigurasi batch untuk peringatan event didukung. Untuk informasi lebih lanjut tentang alur kerja, lihat Kelola alur kerja.

1. Dapatkan ID resource node alur kerja.

   1. Masuk ke Konsol Cloud Monitor.

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

   3. Pada tab Event Monitoring, atur Product ke Realtime Compute for Apache Flink dan Event Name ke Workflow Task Status Change, lalu klik Filter by source.

   4. Temukan ID resource node alur kerja di bawah ini.

      Pada halaman Event Monitoring, pilih Realtime Compute for Apache Flink dari daftar drop-down Product. Di daftar event, temukan catatan dengan nama event flink:Workflow:TaskStateChange Workflow Task Status Change. Anda dapat melihat ID resource node alur kerja di kolom Resource.

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

      Parameter	Deskripsi
      <AlibabaCloudAccountIdOfWorkspace>	ID akun Alibaba Cloud yang memiliki ruang kerja Flink.
      <workspaceId-namespaceId>	Kombinasi dari workspaceId dan namespaceId, digabungkan dengan tanda hubung (-). workspaceId: ID ruang kerja. Untuk informasi lebih lanjut, lihat Manajemen dan operasi ruang kerja. namespaceId: Nama namespace.
      <workflowDefinitionName>	Nama alur kerja.
      <taskDefinitionName>	Nama node alur kerja.

      Catatan

      Umumnya terdapat penundaan beberapa menit sebelum event perubahan status alur kerja muncul di CloudMonitor.

2. Berlangganan notifikasi event.

   1. Pada panel navigasi kiri, pilih Event Center > Event Subscription.

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

   3. Pada halaman Create Subscription Policy, atur parameter kebijakan langganan. Untuk informasi selengkapnya mengenai parameter tersebut, lihat Mengelola langganan event (disarankan).

      • Subscription Type: System Event.

      • Product: Pilih Realtime Compute for Apache Flink.

      • Event Name: Pilih Workflow Task Status Change.

      • Event Content: Mendukung pemasukan parameter seperti toState: FAILED (alur kerja gagal), toState: SUCCESS (alur kerja berhasil), dan fromState: SCHEDULED, toState: RUNNING (status alur kerja berubah dari dijadwalkan menjadi berjalan).

      • Event Resource: Masukkan ID resource alur kerja yang diperoleh pada Langkah 1. Pisahkan beberapa ID dengan koma (,).

      • Event Type, Event Level, Application Group: Jangan atur apa pun.

Konfigurasikan satu pekerjaan (Konsol Manajemen)

Anda dapat membuat aturan peringatan baru untuk pekerjaan target, atau membuat templat aturan peringatan lalu menggunakannya untuk membuat peringatan bagi pekerjaan target. Hal ini dapat mempercepat konfigurasi pemantauan dan peringatan.

1. Buka halaman konfigurasi peringatan.

   1. Masuk ke Konsol Manajemen dan klik Console pada kolom Actions untuk ruang kerja target.

   2. Pada halaman O&M > Deployments, klik nama pekerjaan target.

   3. Klik tab Alarm.

2. Pada tab Alert Rules, pilih Add Rule > Custom Rule.

   Anda juga dapat memilih Add Rule > Create Rule by Template. Dengan menambahkan dan menggunakan templat peringatan, Anda dapat membuat aturan peringatan secara langsung atau dengan sedikit modifikasi, sehingga mempercepat proses konfigurasi.

3. Masukkan informasi aturan peringatan.

   Kategori	Parameter	Deskripsi
   Rule	Name	Harus dimulai dengan huruf dan hanya boleh berisi huruf kecil, angka, dan garis bawah (_). Panjangnya dibatasi antara 3 hingga 64 karakter.
   	Description	Catatan tentang aturan tersebut.
   	Content	Konfigurasikan kondisi yang memicu peringatan. Sistem membandingkan nilai metrik yang ditentukan dengan ambang batas pada interval tertentu. Jika hasilnya memenuhi kondisi, peringatan akan dipicu secara otomatis. Metric: Restart Count in 1 Minute: Jumlah kali Manajer Pekerjaan melakukan restart dalam 1 menit. Checkpoint Count in 5 Minutes: Jumlah checkpoint yang berhasil dalam 5 menit. Emit Delay: Latensi bisnis, yaitu selisih waktu antara saat data dihasilkan dan saat data meninggalkan operator Source. Satuannya detik. Penting Waktu pembuatan data bergantung pada stempel waktu yang dicatat di sistem eksternal. Jika sistem eksternal tidak memiliki stempel waktu, atau jika stempel waktu tersebut salah ditulis, nilai Emit Delay akan tidak akurat dan tidak mencerminkan latensi sebenarnya. Konfigurasikan peringatan dengan beberapa metrik untuk menentukan event sebenarnya. Untuk informasi lebih lanjut, lihat Contoh dan templat konfigurasi yang direkomendasikan untuk pemantauan dan peringatan. IN RPS: Jumlah catatan input per detik. Satuannya catatan/detik. OUT RPS: Jumlah catatan output per detik. Satuannya catatan/detik. Source Idle Time: Waktu sumber tidak memproses data. Satuannya milidetik. Job Failed: Pekerjaan gagal. Time Difference: Panjang jendela waktu data historis yang diperiksa sistem mundur untuk setiap pemeriksaan. Satuannya menit. Comparator: Mendukung >= dan <=. Threshold: Nilai untuk dibandingkan dengan metrik. Jika Anda memilih operator >=, sistem menggunakan nilai MAX dari sumbu vertikal. Jika nilai maksimum dalam selisih waktu >= ambang batas, aturan peringatan dipicu. Jika Anda memilih operator <=, sistem menggunakan nilai MIN dari sumbu vertikal. Jika nilai minimum dalam selisih waktu <= ambang batas, aturan peringatan dipicu. Sebagai contoh, asumsikan Anda memantau metrik "Checkpoint Count in 5 Minutes". Selisih waktu diatur ke 10 menit, ambang batasnya 2, dan operatornya "<=". Setiap menit, sistem memeriksa data historis dari 10 menit terakhir. Jika menemukan interval 5 menit di mana jumlah checkpoint yang berhasil kurang dari atau sama dengan 2, sistem akan memicu peringatan.
   	Effective Period	Waktu ketika pemantauan peringatan aktif. Anda dapat menentukannya agar hanya aktif pada siang hari (09.00–18.00). Secara default, aktif sepanjang hari.
   	Alarm Rate	Kirim peringatan hanya sekali dalam jumlah menit berkelanjutan tertentu. Mendukung 1 menit hingga 1440 menit (24 jam).
   Notification Method	Notification Method	Anda dapat memilih beberapa metode notifikasi. Metode yang didukung adalah: DingTalk Email SMS Webhook Telepon Pastikan nomor telepon penerima telah diverifikasi. Jika tidak, metode ini tidak akan berfungsi. Anda dapat mengklik Notification object management di bawah. Jika kolom Phone untuk kontak target pada tab kontak menunjukkan Unverified, klik untuk menyelesaikan verifikasi. Penting Pastikan Anda telah membuat dan menambahkan kontak notifikasi yang tersedia. Jika tidak, notifikasi peringatan akan gagal. Misalnya, jika Anda memilih DingTalk sebagai metode notifikasi, pilih DingTalk dan tambahkan kontak notifikasi DingTalk bertipe chatbot DingTalk.
   	Notification Object	Anda dapat memberi notifikasi ke beberapa kontak sekaligus. Anda dapat memilih atau mencari kontak. Sebelum memilih kontak, Anda harus mengklik Notification object management di sebelah kanan untuk membuatnya. Untuk informasi lebih lanjut, lihat Manajemen dan operasi ruang kerja.
   	Alarm Noise Reduction	Klik Advanced Settings, lalu Anda dapat mengaktifkan sakelar Alarm Noise Reduction. Setelah Anda mengaktifkan pengurangan kebisingan peringatan, peringatan tidak akan dikirim untuk skenario di mana pekerjaan dapat pulih dengan cepat, seperti failover jangka pendek yang dipicu oleh penjadwalan kluster atau penyetelan otomatis. Peringatan hanya dikirim ketika kondisi ambang batas yang Anda tetapkan terpenuhi secara berkelanjutan.
   	No Data Alarms	Klik Advanced Settings, lalu Anda dapat mengaktifkan sakelar No Data Alarms dan memasukkan informasi waktu tanpa data berkelanjutan. Setelah Anda mengaktifkan fitur ini, sistem memantau skenario di mana tidak ada data pemantauan yang dilaporkan. Jika tidak ada data yang dilaporkan dalam periode waktu yang dipilih, peringatan akan dipicu. Tidak adanya data pemantauan biasanya dilaporkan ketika JobManager abnormal, pekerjaan berhenti secara tak terduga, atau tautan pelaporan mengalami gangguan.

4. Klik OK.

   Aturan peringatan yang disimpan diaktifkan secara default dan muncul dalam daftar aturan peringatan. Anda dapat memilih untuk menghentikan, mengedit, atau menghapusnya.

Konfigurasikan satu atau beberapa pekerjaan (konsol ARMS)

1. Masuk ke Konsol Manajemen.

2. Pada kolom Actions untuk ruang kerja target, pilih More > Monitoring Indicator Configuration untuk menuju konsol ARMS.

   Nama ruang kerja, ID ruang kerja, dan nama instance Prometheus yang sesuai ditampilkan di bagian atas.

   Panel navigasi kiri mencakup Dashboard List, Service Discovery, Metric Management, Alert Rules, dan Settings. Status agen ditampilkan di kanan atas. Pada tab Metrics halaman Service Discovery, Anda dapat memfilter metrik berdasarkan nama pekerjaan, jenis metrik, dan kondisi lainnya. Daftar metrik menampilkan nama metrik, nama pekerjaan, jenis metrik, dan informasi lainnya.

3. Klik Alert Rules di sebelah kiri untuk membuat aturan peringatan.

   • Check Type: Mendukung peringatan metrik melalui ambang batas statis dan PromQL kustom (tidak termasuk metrik peringatan yang sudah didukung oleh Flink).

   • Filter Conditions: Konfigurasi peringatan batch didukung. Untuk Namespace, masukkan nama namespace. Memilih semua menunjukkan semua namespace di ruang kerja. Untuk Create Deployment, masukkan deployment ID pekerjaan target di namespace (ditemukan pada tab Configuration pekerjaan Flink). Memilih semua menunjukkan semua pekerjaan di namespace.

   Untuk informasi lebih lanjut tentang parameter konfigurasi, lihat Buat aturan peringatan Prometheus. Anda juga dapat membuat templat aturan peringatan Prometheus. Untuk informasi lebih lanjut, lihat Buat templat aturan peringatan Prometheus.