Tetapkan CloudWatch tingkat pelaporan metrik - Layanan Terkelola untuk Apache Flink

Amazon Managed Service untuk Apache Flink (Amazon MSF) sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Tetapkan CloudWatch tingkat pelaporan metrik

Anda dapat mengontrol tingkat metrik aplikasi yang dibuat aplikasi Anda. Layanan Terkelola untuk Apache Flink mendukung tingkat metrik berikut:

  • Application (Aplikasi): Aplikasi hanya melaporkan tingkat metrik tertinggi untuk setiap aplikasi. Layanan Terkelola untuk metrik Apache Flink dipublikasikan di tingkat Aplikasi secara default.

  • Task (Tugas): Aplikasi ini melaporkan dimensi metrik khusus tugas untuk metrik yang ditentukan dengan tingkat pelaporan metrik Tugas, seperti jumlah catatan masuk dan keluar dari aplikasi per detik.

  • Operator: Aplikasi ini melaporkan dimensi metrik khusus operator untuk metrik yang ditentukan dengan tingkat pelaporan metrik Operator, seperti metrik untuk setiap operasi filter atau peta.

  • Paralelism (Paralelisme) Aplikasi melaporkan metrik tingkat Task dan Operator untuk setiap utas eksekusi. Tingkat pelaporan ini tidak disarankan untuk aplikasi dengan pengaturan Paralelisme di atas 64 karena biaya yang berlebihan.

    catatan

    Anda hanya harus menggunakan tingkat metrik ini untuk pemecahan masalah karena jumlah data metrik yang dihasilkan layanan. Anda hanya dapat mengatur tingkat metrik ini menggunakan CLI. Tingkat metrik ini tidak tersedia di konsol.

Tingkat default adalah Application (Aplikasi). Aplikasi melaporkan metrik pada tingkat saat ini dan semua tingkat yang lebih tinggi. Misalnya, jika tingkat pelaporan diatur ke Operator, aplikasi melaporkan metrik Application (Aplikasi), Task (Tugas), dan Operator (Operator).

Anda menetapkan tingkat pelaporan CloudWatch metrik menggunakan MonitoringConfiguration parameter CreateApplicationtindakan, atau MonitoringConfigurationUpdate parameter UpdateApplicationtindakan. Contoh permintaan UpdateApplicationtindakan berikut ini menetapkan tingkat pelaporan CloudWatch metrik ke Tugas:

{
   "ApplicationName": "MyApplication",  
   "CurrentApplicationVersionId": 4,
   "ApplicationConfigurationUpdate": { 
      "FlinkApplicationConfigurationUpdate": { 
         "MonitoringConfigurationUpdate": { 
            "ConfigurationTypeUpdate": "CUSTOM",
            "MetricsLevelUpdate": "TASK"
         }
      }
   }
}

Anda juga dapat mengonfigurasi tingkat pencatatan menggunakan parameter LogLevel dari tindakan CreateApplication atau parameter LogLevelUpdate dari tindakan UpdateApplication. Anda dapat menggunakan tingkat log berikut:

  • ERROR: Mencatat peristiwa kesalahan yang berpotensi dapat dipulihkan

  • WARN: Mencatat peristiwa peringatan yang mungkin menyebabkan kesalahan.

  • INFO: Mencatat peristiwa informasi.

  • DEBUG: Mencatat peristiwa debugging umum.

Untuk informasi selengkapnya tentang tingkat pencatatan Log4j, lihat Tingkat Log Kustom di dokumentasi Apache Log4j.