SP.processor.stats()
定義
sp.processor.stats()現在の ストリーム プロセシング インスタンス で現在実行中の Stream プロセッサ の統計を含むドキュメントを返します。
このコマンドは、ストリーム プロセシング インスタンスに接続されている間のみ呼び出せます。
このコマンドには、
mongoshバージョン `` 2.0が必要です。
構文
sp.processor.stats()メソッドの構文は次のとおりです。
sp.processor.stats()
コマンドフィールド
sp.processor.stats() 次のフィールドを取ります。
フィールド | タイプ | 必要性 | 説明 |
|---|---|---|---|
options | オブジェクト | 任意 | 統計レポートのさまざまなオプション設定を定義するオブジェクト。 |
options.scale | integer | 任意 | 出力に記述される項目のサイズに使用する単位。 1024に設定されている場合、出力ドキュメントにはサイズがキロバイト単位で表示されます。 デフォルトはバイトです。 |
verbose | ブール値 | 任意 | 出力ドキュメントの冗長レベルを指定するフラグ。 trueに設定されている場合、出力ドキュメントには、パイプライン内の各演算子の統計を報告するサブドキュメントが含まれます。 デフォルトは false です。 |
動作
sp.processor.stats() は、指定されたストリーム プロセッサに関する統計を含むドキュメントをSTDOUTに返します。 これらの統計には、次のものが含まれますが、これらに限定されません。
取り込まれ処理されたメッセージの数
すべての入力と出力の合計サイズ
プロセッサの状態を保存するために使用されるメモリの量
現在実行中のストリーム プロセッサではのみsp.processor.stats()を呼び出すことができます。 停止したストリーム プロセッサでこのコマンドを呼び出すと、 mongoshはエラーを返します。
アクセス制御
sp.processor.stats()を実行しているユーザーにはatlasAdminロールが必要です。
例
次の例では、 solarDemoというストリーム プロセッサの統計を取得するためにsp.solarDemo.stats()を呼び出した場合に予想される応答を示しています。
sp.solarDemo.stats()
{ ok: 1, ns: '6500aa277fdbdb6e443a992e.63c1928d768e39423386aa16.solarDemo', stats: { name: 'solarDemo', processorId: '65f9fea5c5154385174af71e', status: 'running', scaleFactor: Long('1'), inputMessageCount: Long('926'), inputMessageSize: 410310, outputMessageCount: Long('383'), outputMessageSize: 425513, dlqMessageCount: Long('0'), dlqMessageSize: Long('0'), stateSize: Long('4504'), watermark: ISODate('2024-03-19T22:16:49.523Z'), ok: 1 }, pipeline: [ { '$source': { connectionName: 'sample_stream_solar', timeField: { '$dateFromString': { dateString: '$timestamp' } } } }, { '$match': { '$expr': { '$ne': [ '$device_id', 'device_8' ] } } }, { '$tumblingWindow': { interval: { size: 10, unit: 'second' }, pipeline: [ { '$group': { _id: [Object], max_temp: [Object], max_watts: [Object], min_watts: [Object], avg_watts: [Object], median_watts: [Object] } } ] } }, { '$merge': { into: { connectionName: 'mongodb1', db: 'solar_db', coll: 'solar_coll' }, on: [ '_id' ] } } ] }