定义
版本7.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 } { _id: { device_id: 'device_0' }, max_temp: 18, max_watts: 210, min_watts: 68, avg_watts: 157, median_watts: 193 } { _id: { device_id: 'device_10' }, max_temp: 21, max_watts: 128, min_watts: 4, avg_watts: 66, median_watts: 4 } { _id: { device_id: 'device_9' }, max_temp: 10, max_watts: 227, min_watts: 66, avg_watts: 131.4, median_watts: 108 }