Menulis pesan khusus ke CloudWatch Log - Layanan Terkelola untuk Apache Flink
Menulis ke CloudWatch log menggunakan Log4JMenulis ke CloudWatch log menggunakan SLF4J

Amazon Managed Service untuk Apache Flink 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.

Menulis pesan khusus ke CloudWatch Log

Anda dapat menulis pesan khusus ke Layanan Terkelola untuk log aplikasi Apache Flink. CloudWatch Anda melakukannya menggunakan pustaka log4j Apache atau pustaka Simple Logging Facade for Java (SLF4J).

Menulis ke CloudWatch log menggunakan Log4J

  1. Tambahkan dependensi berikut ke file pom.xml aplikasi Anda:

    <dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-api</artifactId>
    <version>2.6.1</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-core</artifactId>
    <version>2.6.1</version>
</dependency>

  2. Sertakan objek dari pustaka:

    import org.apache.logging.log4j.Logger;

  3. Beri contoh objek Logger, yang meneruskan di kelas aplikasi Anda:

    private static final Logger log = LogManager.getLogger.getLogger(YourApplicationClass.class);

  4. Tulis ke log menggunakan log.info. Sejumlah besar pesan ditulis ke log aplikasi. Untuk membuat pesan kustom Anda lebih mudah difilter, gunakan tingkat log aplikasi INFO.

    log.info("This message will be written to the application's CloudWatch log");

Aplikasi ini menulis catatan ke log dengan pesan yang serupa dengan berikut ini:

{
  "locationInformation": "com.amazonaws.services.managed-flink.StreamingJob.main(StreamingJob.java:95)", 
  "logger": "com.amazonaws.services.managed-flink.StreamingJob", 
  "message": "This message will be written to the application's CloudWatch log", 
  "threadName": "Flink-DispatcherRestEndpoint-thread-2", 
  "applicationARN": "arn:aws:kinesisanalyticsus-east-1:123456789012:application/test", 
  "applicationVersionId": "1", "messageSchemaVersion": "1", 
  "messageType": "INFO" 
}

Menulis ke CloudWatch log menggunakan SLF4J

  1. Tambahkan dependensi berikut ke file pom.xml aplikasi Anda:

    <dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
    <version>1.7.7</version>
    <scope>runtime</scope>
</dependency>

  2. Sertakan objek dari pustaka:

    import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

  3. Beri contoh objek Logger, yang meneruskan di kelas aplikasi Anda:

    private static final Logger log = LoggerFactory.getLogger(YourApplicationClass.class);

  4. Tulis ke log menggunakan log.info. Sejumlah besar pesan ditulis ke log aplikasi. Untuk membuat pesan kustom Anda lebih mudah difilter, gunakan tingkat log aplikasi INFO.

    log.info("This message will be written to the application's CloudWatch log");

Aplikasi ini menulis catatan ke log dengan pesan yang serupa dengan berikut ini:

{
  "locationInformation": "com.amazonaws.services.managed-flink.StreamingJob.main(StreamingJob.java:95)", 
  "logger": "com.amazonaws.services.managed-flink.StreamingJob", 
  "message": "This message will be written to the application's CloudWatch log", 
  "threadName": "Flink-DispatcherRestEndpoint-thread-2", 
  "applicationARN": "arn:aws:kinesisanalyticsus-east-1:123456789012:application/test", 
  "applicationVersionId": "1", "messageSchemaVersion": "1", 
  "messageType": "INFO" 
}