Docs Home

/ /

Atlas Stream Processing

Docs Home

/ /

mongosh メソッド

Atlas Stream Processing

Atlas Stream Processing

SP.processor.stats()（mongoshメソッド）

定義

sp.processor.stats()

バージョン の新機能:7.0 現在のストリームプロセシングワークスペースで実行中の Stream プロセッサの統計を含むドキュメントを返します。

互換性

このメソッドは Atlas Stream Processing ワークスペースでサポートされています。

構文

sp.processor.stats()メソッドの構文は次のとおりです。

sp.processor.stats( { options: { scale: <int>, verbose: <boolean> } } )

コマンドフィールド

sp.processor.stats() 次のフィールドを取ります。

フィールド	タイプ	必要性	説明
`options`	オブジェクト	任意	統計レポートのさまざまなオプション設定を定義するオブジェクト。
`options.scale`	integer	任意	出力に記述される項目のサイズに使用する単位。 `1024`に設定されている場合、出力ドキュメントにはサイズがキロバイト単位で表示されます。デフォルトはバイトです。
`options.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' ]
      }
    }
  ]
}

詳細

ストリームプロセッサの管理

戻る

SP.processor.start

SP.processor.stop