Docs 菜单
Docs 主页
/
MongoDB Manual
/
参考
/
mongosh 方法
/
Atlas Stream Processing 方法

sp.processor.stats()

在此页面上

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

定义

sp.processor.stats()

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

您只能在连接到流处理实例时调用此命令。

此命令需要mongosh版本 ≥ 2 。 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() →

在此页面上