sp.processor.stats() (método mongosh)

Definición

sp.processor.stats()

Devuelve un documento que contiene estadísticas de una tarea en ejecución Stream Processor en el Stream Processing Workspaceactual.

Solo puedes invocar este comando mientras estés conectado a un entorno de trabajo de Stream Processing.

Este comando requiere mongosh versión ≥ 2.0.

Compatibilidad

Este método es compatible en espacios de trabajo de Atlas Stream Processing.

Sintaxis

El método sp.processor.stats() tiene la siguiente sintaxis:

sp.processor.stats( { options: { scale: <int>, verbose: <boolean> } } )

Campos de comandos

sp.processor.stats() toma estos campos:

Campo	Tipo	Necesidad	Descripción
`options`	Objeto	Opcional	Objeto que define varias configuraciones opcionales para su informe de estadísticas.
`options.scale`	entero	Opcional	Unidad a utilizar para el tamaño de los elementos descritos en el resultado. Si se establece en `1024`, el documento de salida muestra los tamaños en kibibytes. Por defecto en bytes.
`options.verbose`	booleano	Opcional	Indicador que especifica el nivel de verbosidad del documento de salida. Si se establece en `true`, el documento de salida contiene un subdocumento que informa las estadísticas de cada operador individual en tu pipeline. Por defecto, es `false`.

Comportamiento

sp.processor.stats() devuelve un documento con estadísticas sobre el procesador de flujo especificado a STDOUT. Estas estadísticas incluyen, pero no se limitan a:

El número de mensajes ingeridos y procesados
El tamaño total de toda la entrada y salida
La cantidad de memoria utilizada para almacenar el estado del procesador

Solo puedes invocar sp.processor.stats() en un procesador de flujo que esté en ejecución. Si intentas invocar este comando en un procesador de flujos detenido, mongosh devolverá un error.

Control de acceso

El usuario que ejecuta sp.processor.stats() debe tener el atlasAdmin rol.

Ejemplo

El siguiente ejemplo muestra una respuesta esperada al llamar a sp.solarDemo.stats() para obtener las estadísticas de un procesador de transmisión llamado 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' ]
      }
    }
  ]
}

Obtén más información

Gestionar procesadores de flujo

Volver

sp.processor.start

sp.processor.stop