定义
sp.processor.sample()从当前 流处理工作区 上当前运行的 流处理器 返回采样结果数组。
只有在连接到流处理工作区时才能调用此命令。
此命令需要
mongosh版本 ≥ 2.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}{ _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}