Definição
sp.processor.stats()Retorna um documento contendo estatísticas de um processador de stream atualmente em execução no espaço de trabalho de processamento de stream atual.
Você só pode invocar este comando enquanto estiver conectado a um espaço de trabalho de processamento de fluxo.
Este comando requer
mongoshversão ≥ 2.0.
Compatibilidade
Esse método é suportado em Atlas Stream Processing Workspaces.
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 |
|---|---|---|---|
| objeto | Opcional | Objeto que define várias configurações opcionais para seu relatório de estatísticas. |
| inteiro | Opcional | Unidade a ser usada para o tamanho dos itens descritos na saída. Se definido como |
| booleano | Opcional | Sinalizador que especifica o nível de verbosidade do documento de saída. Se definido como |
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' ] } } ] }