b.processor.stats()
Definição
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.
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' ] } } ] }