Realtime Compute for Apache Flink memungkinkan Anda melihat metrik untuk menganalisis penyebaran. Anda dapat melihat metrik pada tab konsol pengembangan Realtime Compute for Apache Flink atau mengonfigurasi parameter untuk melaporkan metrik ke platform lain. Topik ini menjelaskan cara mengonfigurasi metrik kustom dan melaporkan metrik ke layanan Prometheus yang dikelola sendiri, Layanan Log Sederhana, Kafka, platform yang dikelola sendiri, atau beberapa platform.
Tindakan pencegahan
Anda dapat mengonfigurasi parameter untuk melaporkan metrik hanya ke layanan Prometheus yang dikelola sendiri, Layanan Log Sederhana, atau Kafka. Anda juga dapat mengonfigurasi parameter untuk mengumpulkan dan melaporkan metrik ke beberapa platform.
Laporkan metrik ke beberapa platform
Jika ingin mengumpulkan dan melaporkan metrik ke beberapa platform, Anda harus memodifikasi konfigurasi parameter metrics.reporters. Jika metrik dilaporkan ke beberapa platform, biaya pengumpulan metrik meningkat. Untuk informasi lebih lanjut, lihat Laporkan metrik ke beberapa platform.
Laporkan metrik ke platform selain konsol Realtime Compute for Apache Flink
Application Real-Time Monitoring Service (ARMS) atau CloudMonitor tidak lagi diaktifkan bersama dengan Realtime Compute for Apache Flink. Dalam hal ini, metrik tidak ditampilkan di konsol Realtime Compute for Apache Flink. Anda dapat melihat metrik pada platform tempat metrik dilaporkan.
Konfigurasi peringatan yang ada di konsol Realtime Compute for Apache Flink menjadi tidak valid. Untuk informasi lebih lanjut, lihat Konfigurasikan pemantauan dan peringatan. Anda tidak dapat lagi mengonfigurasi aturan peringatan di konsol Realtime Compute for Apache Flink. Anda harus mengonfigurasi aturan peringatan pada platform tempat metrik dilaporkan.
Platform tempat metrik kustom dilaporkan
Laporkan metrik ke layanan Prometheus yang dikelola sendiri
Pastikan koneksi jaringan telah dibuat antara Realtime Compute for Apache Flink dan layanan Prometheus yang dikelola sendiri. Kemudian, masuk ke konsol Realtime Compute for Apache Flink dan lakukan operasi berikut: Di panel navigasi sisi kiri, klik Deployments. Pada halaman Deployments, klik nama penyebaran yang diinginkan di kolom Nama. Pada tab Configuration, klik Edit di pojok kanan atas bagian Parameters, tambahkan kode berikut ke bidang Other Configuration, dan kemudian ubah nilai parameter terkait layanan Prometheus yang dikelola sendiri. Untuk informasi lebih lanjut tentang metode konfigurasi, lihat Bagaimana cara mengonfigurasi parameter kustom untuk penyebaran yang sedang berjalan?
metrics.reporters: promgatewayappmgr
metrics.reporter.promgatewayappmgr.groupingKey: 'deploymentName={{deploymentName}};deploymentId={{deploymentId}};jobId={{jobId}}'
metrics.reporter.promgatewayappmgr.jobName: '{{deploymentName}}'
metrics.reporter.promgatewayappmgr.factory.class: org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporterFactory
metrics.reporter.promgatewayappmgr.host: pushgateway host
metrics.reporter.promgatewayappmgr.port: pushgateway portDalam kode, Anda harus mengganti pushgateway host dengan nama host Pushgateway Anda dan mengganti pushgateway port dengan nomor port Pushgateway Anda. Sistem secara otomatis mengganti nilai parameter deploymentName, deploymentId, dan jobId.
Koneksi jaringan yang dibuat antara Realtime Compute for Apache Flink dan layanan Prometheus yang dikelola sendiri harus memenuhi persyaratan berikut:
Jika layanan Prometheus yang dikelola sendiri berada di virtual private cloud (VPC) yang sama dengan ruang kerja Realtime Compute for Apache Flink, Anda harus memastikan bahwa blok CIDR dari Realtime Compute for Apache Flink dapat mengakses grup keamanan layanan Prometheus yang dikelola sendiri.
Jika layanan Prometheus yang dikelola sendiri memiliki titik akhir publik dan berada di VPC yang berbeda dari ruang kerja Realtime Compute for Apache Flink, Anda harus mengonfigurasi akses Internet untuk Realtime Compute for Apache Flink. Untuk informasi lebih lanjut, lihat Bagaimana cara Realtime Compute for Apache Flink mengakses Internet?
Jika layanan Prometheus yang dikelola sendiri hanya memiliki titik akhir VPC dan berada di VPC yang berbeda dari ruang kerja Realtime Compute for Apache Flink, Anda harus membuat koneksi antar-VPC. Untuk informasi lebih lanjut, lihat Bagaimana cara Realtime Compute for Apache Flink mengakses layanan lintas VPC?
Laporkan metrik ke Layanan Log Sederhana
Pastikan koneksi jaringan telah dibuat antara Realtime Compute for Apache Flink dan Layanan Log Sederhana. Kemudian, masuk ke konsol Realtime Compute for Apache Flink dan lakukan operasi berikut: Di panel navigasi sisi kiri, klik Deployments. Pada halaman Deployments, klik nama penyebaran yang diinginkan di kolom Nama. Pada tab Configuration, klik Edit di pojok kanan atas bagian Parameters, tambahkan kode berikut ke bidang Other Configuration, dan kemudian ubah nilai parameter terkait Layanan Log Sederhana. Untuk informasi lebih lanjut tentang metode konfigurasi, lihat Bagaimana cara mengonfigurasi parameter kustom untuk penyebaran yang sedang berjalan?
metrics.reporters: sls
metrics.reporter.sls.factory.class: org.apache.flink.metrics.sls.SLSReporterFactory
metrics.reporter.sls.project: proyek Layanan Log Sederhana
metrics.reporter.sls.logStore: penyimpanan log Layanan Log Sederhana
metrics.reporter.sls.endPoint: titik akhir Layanan Log Sederhana
metrics.reporter.sls.accessId: ID AccessKey yang digunakan untuk terhubung ke Layanan Log Sederhana
metrics.reporter.sls.accessKey: Rahasia AccessKey yang digunakan untuk terhubung ke Layanan Log Sederhana
metrics.reporter.sls.extraTags: deploymentId={{ deploymentId }};deploymentName={{ deploymentName}};namespace={{ namespace }}Dalam kode, Anda harus mengonfigurasi parameter terkait Layanan Log Sederhana. Sistem secara otomatis mengganti nilai parameter deploymentId, deploymentName, dan namespace. Untuk informasi lebih lanjut tentang pasangan AccessKey akun, lihat Bagaimana cara melihat pasangan AccessKey akun?
Tentukan penyimpanan metrik saat melaporkan metrik ke Layanan Log Sederhana
Untuk melaporkan metrik ke penyimpanan metrik tertentu, Anda harus menambahkan konfigurasi berikut dan mengubah nilai metrics.reporter.sls.logStore menjadi nama penyimpanan metrik Anda.
metrics.reporter.sls.toMetricStore: true
metrics.reporter.sls.logStore: <Nama penyimpanan metrik Anda>Laporkan metrik ke Kafka
Pastikan koneksi jaringan telah dibuat antara Realtime Compute for Apache Flink dan Kafka. Kemudian, masuk ke konsol Realtime Compute for Apache Flink dan lakukan operasi berikut: Di panel navigasi sisi kiri, klik Deployments. Pada halaman Deployments, klik nama penyebaran yang diinginkan di kolom Nama. Pada tab Configuration, klik Edit di pojok kanan atas bagian Parameters, tambahkan kode berikut ke bidang Other Configuration, dan kemudian ubah nilai parameter terkait Kafka. Untuk informasi lebih lanjut tentang metode konfigurasi, lihat Bagaimana cara mengonfigurasi parameter kustom untuk penyebaran yang sedang berjalan?
metrics.reporters: monitor
metrics.reporter.monitor.factory.class: org.apache.flink.metrics.monitor.KafkaReporterFactory
metrics.reporter.monitor.kafka.bootstrap.servers: alamat broker Kafka
metrics.reporter.monitor.topicName: nama topik Kafka
metrics.reporter.monitor._FLINK_CLUSTER_NAME: '{{ deploymentName }}'
metrics.reporter.monitor._JOB_NAME: '{{ deploymentName }}'
metrics.reporter.monitor._NAMESPACE_NAME: '{{ namespace }}'Dalam kode, Anda harus mengonfigurasi parameter terkait kluster Kafka yang dikelola sendiri. Sistem secara otomatis mengganti nilai parameter deploymentName dan namespace.
Laporkan metrik ke beberapa platform
Panggil Operasi API ARMS untuk melaporkan metrik ke platform yang dikelola sendiri
Jika Anda memilih Alibaba Cloud Managed Service for Prometheus saat membeli ruang kerja Realtime Compute for Apache Flink, Anda dapat memanggil Operasi API ARMS untuk mendapatkan metrik Realtime Compute for Apache Flink dan mengintegrasikan metrik ke platform yang dikelola sendiri. Dalam hal ini, Anda dapat melihat metrik pada platform yang dikelola sendiri. Anda juga dapat melihat kurva metrik dan mengonfigurasi aturan peringatan di konsol Realtime Compute for Apache Flink.
Untuk informasi lebih lanjut tentang Operasi API ARMS, lihat Daftar Operasi API berdasarkan fitur. Untuk informasi lebih lanjut tentang metrik operator, lihat Operator Metric.
Laporkan metrik ke konsol Realtime Compute for Apache Flink dan platform lainnya
Jika ingin melihat kurva metrik dan mengonfigurasi aturan peringatan di konsol Realtime Compute for Apache Flink serta melihat metrik pada platform lain, Anda dapat mengonfigurasi parameter untuk melaporkan metrik ke beberapa platform. Ini meningkatkan biaya pengumpulan metrik.
Sebagai contoh, jika Anda ingin melihat metrik di konsol Realtime Compute for Apache Flink dan Layanan Log Sederhana, Anda dapat masuk ke konsol Realtime Compute for Apache Flink dan melakukan operasi berikut: Di panel navigasi sisi kiri, klik Deployments. Pada halaman Deployments, klik nama penyebaran yang diinginkan di kolom Nama. Pada tab Configuration, klik Edit di pojok kanan atas bagian Parameters, tambahkan kode berikut ke bidang Other Configuration, dan kemudian ubah nilai parameter terkait Layanan Log Sederhana.
metrics.reporters: jmx,promappmgr,sls
metrics.reporter.sls.factory.class: org.apache.flink.metrics.sls.SLSReporterFactory
metrics.reporter.sls.project: proyek Layanan Log Sederhana
metrics.reporter.sls.logStore: penyimpanan log Layanan Log Sederhana
metrics.reporter.sls.endPoint: titik akhir Layanan Log Sederhana
metrics.reporter.sls.accessId: ID AccessKey yang digunakan untuk terhubung ke Layanan Log Sederhana
metrics.reporter.sls.accessKey: Rahasia AccessKey yang digunakan untuk terhubung ke Layanan Log Sederhana
metrics.reporter.sls.extraTags: deploymentId={{ deploymentId }};deploymentName={{ deploymentName}};namespace={{ namespace }}Jika parameter metrics.reporters berisi jmx,promappmgr, Anda dapat melihat metrik di konsol Realtime Compute for Apache Flink. Untuk informasi lebih lanjut tentang parameter lainnya, lihat Laporkan metrik ke Layanan Log Sederhana.
Laporkan metrik ke beberapa platform selain konsol Realtime Compute for Apache Flink
Setelah metrik dilaporkan ke beberapa platform selain konsol Realtime Compute for Apache Flink, metrik tidak ditampilkan di konsol Realtime Compute for Apache Flink. Anda harus melihat metrik pada platform tempat metrik dilaporkan. Untuk informasi lebih lanjut, lihat Tindakan pencegahan.
Sebagai contoh, jika ingin melaporkan metrik ke Layanan Log Sederhana dan Kafka, Anda dapat menambahkan kode berikut ke bidang Other Configuration di bagian Parameters pada tab Configuration di konsol Realtime Compute for Apache Flink.
metrics.reporters: sls,monitor
metrics.reporter.sls.factory.class: org.apache.flink.metrics.sls.SLSReporterFactory
metrics.reporter.sls.project: proyek Layanan Log Sederhana
metrics.reporter.sls.logStore: penyimpanan log Layanan Log Sederhana
metrics.reporter.sls.endPoint: titik akhir Layanan Log Sederhana
metrics.reporter.sls.accessId: ID AccessKey yang digunakan untuk terhubung ke Layanan Log Sederhana
metrics.reporter.sls.accessKey: Rahasia AccessKey yang digunakan untuk terhubung ke Layanan Log Sederhana
metrics.reporter.sls.extraTags: deploymentId={{ deploymentId }};deploymentName={{ deploymentName}};namespace={{ namespace }}
metrics.reporter.monitor.factory.class: org.apache.flink.metrics.monitor.KafkaReporterFactory
metrics.reporter.monitor.kafka.bootstrap.servers: alamat broker Kafka
metrics.reporter.monitor.topicName: nama topik Kafka
metrics.reporter.monitor._FLINK_CLUSTER_NAME: '{{ deploymentName }}'
metrics.reporter.monitor._JOB_NAME: '{{ deploymentName }}'
metrics.reporter.monitor._NAMESPACE_NAME: '{{ namespace }}'Untuk informasi lebih lanjut, lihat Laporkan metrik ke Layanan Log Sederhana dan Laporkan metrik ke Kafka.