Menulis pesan khusus ke CloudWatch Log

Anda dapat menulis pesan kustom 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" 
}