Menu Docs
Página inicial do Docs
/
Manual do MongoDB
/
Referência
/
Métodos de mongosh
/
Atlas Stream Processing

b.processor.stats()

Nesta página

  • Definição
  • Sintaxe
  • Campos de comando
  • Comportamento
  • Controle de acesso
  • Exemplo
  • Saiba mais

Definição

sp.processor.stats()

Retorna um documento contendo estatísticas de um Stream Processor atualmente em execução na Instância deAtlas Stream Processing atual.

Você só pode invocar este comando enquanto estiver conectado a uma instância do Atlas Stream Processing .

Este comando requer mongosh versão ≥ 2.0.

Sintaxe

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

sp.processor.stats()

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.
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 conterá um subdocumento que reporta as estatísticas de cada operador individual em seu pipeline. O padrão é falso.

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

Voltar

max.processor.start