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

Definición

sp.processor.stats()

Nuevo en la 7.0 versión: Devuelve un documento que contiene estadísticas de una ejecución actual Procesador de flujo en el espacio de trabajo de procesamiento de flujo actual.

Compatibilidad

Este método es compatible con los espacios de trabajo de procesamiento de secuencias de Atlas.

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 que se utiliza para el tamaño de los elementos descritos en la salida. Si se establece en `1024`, el documento de salida muestra los tamaños en kibibytes. El valor predeterminado es bytes.
`options.verbose`	booleano	Opcional	Indicador que especifica el nivel de detalle 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 su canalización. El valor predeterminado es `false`.

Comportamiento

sp.processor.stats() Devuelve a STDOUT un documento con estadísticas sobre el procesador de flujo especificado. Estas estadísticas incluyen, entre otras:

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 se puede invocar sp.processor.stats() en un procesador de flujo en ejecución. Si se intenta invocar este comando en un procesador de flujo detenido, mongosh devolverá un error.

Control de acceso

El usuario que ejecuta sp.processor.stats() debe tener la atlasAdmin role.

Ejemplo

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

Administrar procesadores de flujo

Volver

sp.processor.start

sp.processor.stop