Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Managed Service for Apache Flink でのログ記録

実稼働アプリケーションでは、エラーや障害を理解するためにロギングが重要である。ただし、ログ記録サブシステムはログエントリを収集して CloudWatch ログに転送する必要があります。一部のログ記録は適切で望ましいですが、広範なログ記録を行うとサービスが過負荷になり、Flink アプリケーションが遅れる可能性があります。例外や警告をログに記録するのは確かに良い考えです。しかし、Flink アプリケーションによって処理されるすべてのメッセージに対してログ メッセージを生成することはできません。Flink は、高いスループットと低いレイテンシを実現するために最適化されていますが、ロギング サブシステムは最適化されていません。処理されたすべてのメッセージのログ出力を生成することが本当に必要な場合は、Flink アプリケーション DataStream 内で追加の と適切なシンクを使用して、データを Amazon S3 または に送信します CloudWatch。この目的にはJavaロギングシステムを使用しないでください。さらに、Managed Service for Apache FlinkDebug Monitoring Log Level の設定によって大量のトラフィックが生成され、バックプレッシャが発生する可能性があります。アプリケーションの問題を積極的に調査する場合にのみ使用してください。

CloudWatch Logs Insights を使用してログをクエリする

CloudWatch Logs Insights は、ログを大規模にクエリするための強力なサービスです。お客様はその機能を活用してログを迅速に検索して、運用イベント中のエラーを特定して軽減する必要があります。

次のクエリは、すべてのタスク マネージャー ログから例外を検索し、発生時刻に従って例外を並べ替えます。

fields @timestamp, @message
| filter isPresent(throwableInformation.0) or isPresent(throwableInformation) or @message like /(Error|Exception)/
| sort @timestamp desc

その他の便利なクエリについては、クエリの例を参照してください。