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