sp.processor.sample()
定义
sp.processor.sample()从当前 实例 上当前运行的Atlas Stream Processing 流处理器 返回采样结果数组。
您只能在连接到Atlas Stream Processing实例时调用此命令。
此命令需要
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') } }