SP.processor.sample()

項目一覧

定義

構文
コマンドフィールド
動作
アクセス制御
例
詳細

定義

sp.processor.sample()

バージョン7.0の新機能: 現在のストリームプロセシングインスタンスで現在実行中中の Stream プロセッサからサンプル結果の配列を返します。

構文

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

sp.processor.sample()

コマンドフィールド

sp.processor.sample() フィールドは含まれません。

動作

sp.processor.sample() は、名前付きの現在実行中のストリームプロセッサからのサンプリング結果の配列をSTDOUTに返します。このコマンドは、 CTRL-Cを使用してキャンセルするまで、または返されたサンプルが累積40 MBに達するまで継続的に実行されます。

アクセス制御

sp.processor.sample()を実行しているユーザーにはatlasAdminロールが必要です。

例

次の例は、 solarDemoというストリームプロセッサからのサンプリングに対してsp.solarDemo.sample()を呼び出すことによる予想される応答を示しています。

sp.solarDemo.sample()

{
  _id: {
    device_id: 'device_5'
  },
  max_temp: 8,
  max_watts: 66,
  min_watts: 66,
  avg_watts: 66,
  median_watts: 66,
  _stream_meta: {
    window: {
      start: ISODate('2024-03-19T22:09:10.000Z'),
      end: ISODate('2024-03-19T22:09:20.000Z')
    }
  }
}
{
  _id: {
    device_id: 'device_0'
  },
  max_temp: 18,
  max_watts: 210,
  min_watts: 68,
  avg_watts: 157,
  median_watts: 193,
  _stream_meta: {
    window: {
      start: ISODate('2024-03-19T22:09:10.000Z'),
      end: ISODate('2024-03-19T22:09:20.000Z')
    }
  }
}
{
  _id: {
    device_id: 'device_10'
  },
  max_temp: 21,
  max_watts: 128,
  min_watts: 4,
  avg_watts: 66,
  median_watts: 4,
  _stream_meta: {
    window: {
      start: ISODate('2024-03-19T22:09:10.000Z'),
      end: ISODate('2024-03-19T22:09:20.000Z')
    }
  }
}
{
  _id: {
    device_id: 'device_9'
  },
  max_temp: 10,
  max_watts: 227,
  min_watts: 66,
  avg_watts: 131.4,
  median_watts: 108,
  _stream_meta: {
    window: {
      start: ISODate('2024-03-19T22:09:10.000Z'),
      end: ISODate('2024-03-19T22:09:20.000Z')
    }
  }
}

詳細

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

戻る

SP.processor.drop

SP.processor.start