Scrivi messaggi personalizzati in Logs CloudWatch - Servizio gestito per Apache Flink
Scrivi nei CloudWatch log usando Log4JScrivi nei log usando CloudWatch SLF4J

Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Scrivi messaggi personalizzati in Logs CloudWatch

Puoi scrivere messaggi personalizzati nel registro dell'applicazione Managed Service for Apache Flink. CloudWatch Puoi farlo utilizzando la libreria log4j di Apache o la libreria Simple Logging Facade for Java (SLF4J).

Scrivi nei CloudWatch log usando Log4J

  1. Aggiungi le dipendenze seguenti al file pom.xml dell'applicazione:

    <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. Includi l'oggetto dalla libreria:

    import org.apache.logging.log4j.Logger;

  3. Crea un'istanza dell'oggetto Logger, inserendo la classe dell'applicazione:

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

  4. Scrivi nel log utilizzando log.info. Un gran numero di messaggi viene scritto nel log dell'applicazione. Per rendere i messaggi personalizzati più facili da filtrare, utilizza il livello di log INFO dell'applicazione.

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

L'applicazione scrive un record nel log con un messaggio simile al seguente:

{
  "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" 
}

Scrivi nei log usando CloudWatch SLF4J

  1. Aggiungi le dipendenze seguenti al file pom.xml dell'applicazione:

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

  2. Includi gli oggetti della libreria:

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

  3. Crea un'istanza dell'oggetto Logger, inserendo la classe dell'applicazione:

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

  4. Scrivi nel log utilizzando log.info. Un gran numero di messaggi viene scritto nel log dell'applicazione. Per rendere i messaggi personalizzati più facili da filtrare, utilizza il livello di log INFO dell'applicazione.

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

L'applicazione scrive un record nel log con un messaggio simile al seguente:

{
  "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" 
}