sp.processor.stats()
定义
7.0版本新增: 返回一个文档,其中包含当前 流处理实例 上当前运行的 流处理器 的统计信息。
兼容性
语法
sp.processor.stats()
方法使用的语法如下:
sp.processor.stats()
命令字段
sp.processor.stats()
采用这些字段:
字段 | 类型 | 必要性 | 说明 |
---|---|---|---|
| 对象 | Optional | 为统计报告定义各种可选设置的对象。 |
| 整型 | Optional | 用于输出中描述的项目大小的单位。 如果设置为 |
| 布尔 | Optional | 指定输出文档详细程度的标志。 如果设置为 |
行为
sp.processor.stats()
返回一份包含有关指定流处理器的统计信息的文档到STDOUT
。 这些统计数据包括但不限于:
摄取和处理的消息数量
所有输入和输出的总大小
用于存储处理器状态的内存量
您只能在当前正在运行的流处理器上调用sp.processor.stats()
。 如果尝试在已停止的流处理器上调用此命令, mongosh
将返回错误。
访问控制
运行sp.processor.stats()
的用户必须具有atlasAdmin
角色。
例子
以下示例显示了调用sp.solarDemo.stats()
以获取名为solarDemo
的流处理器的统计信息的预期响应:
sp.solarDemo.stats()
{ ok: 1, ns: '6500aa277fdbdb6e443a992e.63c1928d768e39423386aa16.solarDemo', stats: { name: 'solarDemo', processorId: '65f9fea5c5154385174af71e', status: 'running', scaleFactor: Long('1'), inputMessageCount: Long('926'), inputMessageSize: 410310, outputMessageCount: Long('383'), outputMessageSize: 425513, dlqMessageCount: Long('0'), dlqMessageSize: Long('0'), stateSize: Long('4504'), watermark: ISODate('2024-03-19T22:16:49.523Z'), ok: 1 }, pipeline: [ { '$source': { connectionName: 'sample_stream_solar', timeField: { '$dateFromString': { dateString: '$timestamp' } } } }, { '$match': { '$expr': { '$ne': [ '$device_id', 'device_8' ] } } }, { '$tumblingWindow': { interval: { size: 10, unit: 'second' }, pipeline: [ { '$group': { _id: [Object], max_temp: [Object], max_watts: [Object], min_watts: [Object], avg_watts: [Object], median_watts: [Object] } } ] } }, { '$merge': { into: { connectionName: 'mongodb1', db: 'solar_db', coll: 'solar_coll' }, on: [ '_id' ] } } ] }