Docs 菜单
Docs 主页
/
MongoDB Manual
/ / /

sp.processor.sample()

在此页面上

  • 定义
  • 兼容性
  • 语法
  • 命令字段
  • 行为
  • 访问控制
  • 例子
  • 了解详情
sp.processor.sample()

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

Atlas Stream Processing实例支持此方法。

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: {
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