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.
Anmeldung bei Managed Service für Apache Flink
Die Protokollierung ist wichtig für Produktionsanwendungen, um Fehler und Ausfälle zu verstehen. Das Logging-Subsystem muss jedoch Protokolleinträge sammeln und an Logs weiterleiten. Ein gewisses CloudWatch Logging ist zwar in Ordnung und wünschenswert, aber eine umfangreiche Protokollierung kann den Dienst überlasten und dazu führen, dass die Flink-Anwendung ins Hintertreffen gerät. Das Protokollieren von Ausnahmen und Warnungen ist sicherlich eine gute Idee. Sie können jedoch nicht für jede einzelne Nachricht, die von der Flink-Anwendung verarbeitet wird, eine Protokollnachricht generieren. Flink ist für hohen Durchsatz und geringe Latenz optimiert, das Protokollierungs-Subsystem nicht. Falls es wirklich erforderlich ist, für jede verarbeitete Nachricht eine Protokollausgabe zu generieren, verwenden Sie eine zusätzliche Ausgabe DataStream innerhalb der Flink-Anwendung und eine geeignete Senke, um die Daten an Amazon S3 oder CloudWatch zu senden. Verwenden Sie das Java-Protokollierungs-System nicht für diesen Zweck. Darüber hinaus generiert die Debug Monitoring Log Level-Einstellung von Managed Service für Apache Flink eine große Menge an Datenverkehr, was zu Gegendruck führen kann. Sie sollten sie nur verwenden, wenn Sie aktiv Probleme mit der Anwendung untersuchen.
Logs mit CloudWatch Logs Insights abfragen
CloudWatch Logs Insights ist ein leistungsstarker Dienst, um Logs in großem Umfang abzufragen. Kunden sollten seine Funktionen nutzen, um Protokolle schnell zu durchsuchen, um Fehler bei Betriebsereignissen zu identifizieren und zu beheben.
Die folgende Abfrage sucht in allen Task-Manager-Protokollen nach Ausnahmen und ordnet sie nach dem Zeitpunkt, zu dem sie aufgetreten sind.
fields @timestamp, @message | filter isPresent(throwableInformation.0) or isPresent(throwableInformation) or @message like /(Error|Exception)/ | sort @timestamp desc
Weitere nützliche Abfragen finden Sie unter Beispielabfragen.
