Docs 菜单
Docs 主页
/
MongoDB Manual
/
参考
/
mongosh 方法
/
Atlas Stream Processing 方法

sp.processor.sample()

在此页面上

  • 定义
  • 语法
  • 命令字段
  • 行为
  • 访问控制
  • 例子
  • 了解详情

定义

sp.processor.sample()

从当前 流处理实例 上当前运行的 流处理器 返回采样结果数组。

您只能在连接到流处理实例时调用此命令。

此命令需要mongosh版本 ≥ 2 。 0 。

语法

sp.processor.sample()方法采用以下语法：

sp.processor.sample()

命令字段

sp.processor.sample() 不包含任何字段。

行为

sp.processor.sample() 将采样结果数组从当前正在运行的指定流处理器返回到STDOUT 。此命令会持续运行，直到您使用CTRL-C取消它，或者直到返回的样本累计达到40 MB 。

访问控制

运行sp.processor.sample()的用户必须具有atlasAdmin角色。

例子

以下示例显示了调用sp.solarDemo.sample()从名为solarDemo的流处理器进行采样的预期响应：

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: {
    windowStartTimestamp: ISODate('2024-03-19T22:09:10.000Z'),
    windowEndTimestamp: 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: {
    windowStartTimestamp: ISODate('2024-03-19T22:09:10.000Z'),
    windowEndTimestamp: 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: {
    windowStartTimestamp: ISODate('2024-03-19T22:09:10.000Z'),
    windowEndTimestamp: 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: {
    windowStartTimestamp: ISODate('2024-03-19T22:09:10.000Z'),
    windowEndTimestamp: ISODate('2024-03-19T22:09:20.000Z')
  }
}

了解详情

← sp.processor.drop()
sp.processor.start() →

在此页面上