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

Definição

sp.processor.stats()

Novidades na versão 7.0: Retorna um documento contendo estatísticas de um processador defluxo atualmente em execução na instância de processamento de fluxo atual.

Compatibilidade

Este método é suportado em Instâncias de Atlas Stream Processing .

Sintaxe

O método sp.processor.stats() tem a seguinte sintaxe:

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

Campos de comando

sp.processor.stats() usa estes campos:

Campo	Tipo	necessidade	Descrição
`options`	objeto	Opcional	Objeto que define várias configurações opcionais para seu relatório de estatísticas.
`options.scale`	inteiro	Opcional	Unidade a ser usada para o tamanho dos itens descritos na saída. Se definido como `1024`, o documento de saída mostra os tamanhos em kibibytes. O padrão é bytes.
`options.verbose`	booleano	Opcional	Sinalizador que especifica o nível de verbosidade do documento de saída. Se definido como `true`, o documento de saída contém um subdocumento que relata as estatísticas de cada operador individual em seu pipeline. O padrão é `false`.

Comportamento

sp.processor.stats() retorna um documento contendo estatísticas sobre o processador de fluxo especificado para STDOUT. Essas estatísticas incluem, mas não estão limitadas a:

O número de mensagens ingeridas e processadas
O tamanho total de todas as entradas e saídas
A quantidade de memória usada para armazenar o estado do processador

Você só pode invocar sp.processor.stats() em um processador de fluxo atualmente em execução. Se você tentar invocar este comando em um processador de fluxo parado, o mongosh retornará um erro.

Controle de acesso

O usuário que executa sp.processor.stats() deve ter a função atlasAdmin .

Exemplo

O exemplo a seguir mostra uma resposta esperada de chamar sp.solarDemo.stats() para obter as estatísticas de um processador de fluxo chamado 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' ]
      }
    }
  ]
}

Saiba mais

managed processadores de fluxo

Voltar

max.processor.start

sp.processor.stop