Schreiben Sie benutzerdefinierte Nachrichten in CloudWatch Logs - Managed Service für Apache Flink
Schreiben Sie mit CloudWatch Log4J in ProtokolleSchreiben Sie in Logs mit CloudWatch SLF4J

Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Schreiben Sie benutzerdefinierte Nachrichten in CloudWatch Logs

Sie können benutzerdefinierte Nachrichten in das Protokoll Ihrer Managed Service for Apache Flink-Anwendung schreiben. CloudWatch Sie tun dies, indem Sie die Apache log4j-Bibliothek oder die Simple Logging Facade for Java (SLF4J)-Bibliothek verwenden.

Schreiben Sie mit CloudWatch Log4J in Protokolle

  1. Fügen Sie der pom.xml-Datei Ihrer Anwendung die folgenden Abhängigkeiten hinzu:

    <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. Fügen Sie das Objekt aus der Bibliothek hinzu:

    import org.apache.logging.log4j.Logger;

  3. Instanziieren Sie das Logger-Objekt und übergeben Sie Ihre Anwendungsklasse:

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

  4. Schreiben Sie mit log.info in das Protokoll. Eine große Anzahl von Nachrichten wird in das Anwendungsprotokoll geschrieben. Verwenden Sie die INFO-Anwendungsprotokollebene, damit Ihre benutzerdefinierten Nachrichten einfacher gefiltert werden können.

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

Die Anwendung schreibt einen Datensatz in das Protokoll mit einer Meldung wie der folgenden:

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

Schreiben Sie in Logs mit CloudWatch SLF4J

  1. Fügen Sie der pom.xml-Datei Ihrer Anwendung die folgende Abhängigkeit hinzu:

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

  2. Fügen Sie die Objekte aus der Bibliothek hinzu:

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

  3. Instanziieren Sie das Logger-Objekt und übergeben Sie Ihre Anwendungsklasse:

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

  4. Schreiben Sie mit log.info in das Protokoll. Eine große Anzahl von Nachrichten wird in das Anwendungsprotokoll geschrieben. Verwenden Sie die INFO-Anwendungsprotokollebene, damit Ihre benutzerdefinierten Nachrichten einfacher gefiltert werden können.

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

Die Anwendung schreibt einen Datensatz in das Protokoll mit einer Meldung wie der folgenden:

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