Docs 菜单
Docs 主页
/
MongoDB Manual
/ / /

sp.processor.stats()

在此页面上

  • 定义
  • 兼容性
  • 语法
  • 命令字段
  • 行为
  • 访问控制
  • 例子
  • 了解详情
sp.processor.stats()

7.0版本新增: 返回一个文档,其中包含当前 流处理实例 上当前运行的 流处理器 的统计信息。

Atlas Stream Processing实例支持此方法。

sp.processor.stats() 方法使用的语法如下:

sp.processor.stats()

sp.processor.stats() 采用这些字段:

字段
类型
必要性
说明

options

对象

Optional

为统计报告定义各种可选设置的对象。

options.scale

整型

Optional

用于输出中描述的项目大小的单位。 如果设置为1024 ,输出文档显示的大小以 KB 为单位。 默认为字节。

verbose

布尔

Optional

指定输出文档详细程度的标志。 如果设置为true ,则输出文档包含一个子文档,其中报告管道中每个操作符的统计信息。 默认为 false。

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' ]
}
}
]
}

后退

sp.processor.start