Atlas Stream Processing のモニタリングとアラート
Atlas Stream Processing はモニタリングとアラートを提供し、ユーザーはパフォーマンスとステータスのインサイトを活用してワークフローを改善できます。
ストリーム プロセッサの監視メソッド
Atlas Stream Processing は、ストリーム プロセッサに関するオンデマンド レポート作成用に次のメソッドを提供します。
sp.processor.sample()メソッドを使用すると、現在実行中のストリーム プロセッサによって出力されるドキュメントの小さなサンプルを確認できます。 ユーザーは、サンプリングされた結果と期待される結果を比較して、集計パイプライン設計におけるエラーを診断できます。
sp.processor.stats()メソッドは、選択したストリーム プロセッサに関するさまざまな実行時間統計を返します。これには次のものが含まれますが、これらに限定されません。
取り込まれたメッセージの数
正常に処理されたメッセージの数
デッド 文字キューに送信されたメッセージの数
パイプライン状態のメモリ内サイズ
パイプラインの定義
ストリーム プロセッサ アラート
Atlas Stream Processing は、ストリーム プロセッサの状態が変化したときにアラートをトリガーします。 使用可能な Atlas Stream Processing アラートのリストについては、「 Atlas Stream Processingアラート 」を参照してください。 アラート構成の詳細については、「アラート設定の構成 」を参照してください。