sp.processor.stats()

在此页面上

定义

语法
命令字段
行为
访问控制
例子
了解详情

定义

sp.processor.stats()

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

语法

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

来年

sp.processor.stop