sp.processor.sample()
定义
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, _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') } } }