Amazon Managed Service para Apache Flink Amazon se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.
Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Escribe mensajes personalizados en los CloudWatch registros
Puede escribir mensajes personalizados en el registro de la aplicación Managed Service for Apache Flink. CloudWatch Para ello, utilice la biblioteca log4j
Simple Logging Facade for Java (SLF4J)
Temas
Escriba en los CloudWatch registros mediante Log4J
-
Agregue las siguientes dependencias al archivo
pom.xml
de su aplicación:<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>
-
Incluya el objeto de la biblioteca:
import org.apache.logging.log4j.Logger;
-
Cree una instancia del objeto
Logger
, pasando su clase de aplicación:private static final Logger log = LogManager.getLogger.getLogger(
YourApplicationClass
.class); -
Escriba en el registro usando
log.info
. Se escribe una gran cantidad de mensajes en el registro de la aplicación. Para facilitar el filtrado de los mensajes personalizados, utilice el nivel de registroINFO
de la aplicación.log.info("This message will be written to the application's CloudWatch log");
La aplicación escribe un registro en el registro con un mensaje similar al siguiente:
{ "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" }
Escribe en los registros CloudWatch usando SLF4J
-
Agregue la siguiente dependencia al archivo
pom.xml
de su aplicación:<dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.7</version> <scope>runtime</scope> </dependency>
-
Incluya los objetos de la biblioteca:
import org.slf4j.Logger; import org.slf4j.LoggerFactory;
-
Cree una instancia del objeto
Logger
, pasando su clase de aplicación:private static final Logger log = LoggerFactory.getLogger(
YourApplicationClass
.class); -
Escriba en el registro usando
log.info
. Se escribe una gran cantidad de mensajes en el registro de la aplicación. Para facilitar el filtrado de los mensajes personalizados, utilice el nivel de registroINFO
de la aplicación.log.info("This message will be written to the application's CloudWatch log");
La aplicación escribe un registro en el registro con un mensaje similar al siguiente:
{ "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" }