start.processor.sample()
Definição
sp.processor.sample()
Retorna arrays de resultados de amostras de umStream Processor do , atualmente em execução na Instância deAtlas Stream Processing .
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.sample()
tem a seguinte sintaxe:
sp.processor.sample()
Campos de comando
sp.processor.sample()
não possui campos.
Comportamento
sp.processor.sample()
retorna matrizes de resultados amostrados do processador de fluxo nomeado e atualmente em execução para STDOUT
. Esse comando é executado continuamente até que você o cancele usando CTRL-C
ou até que as amostras retornadas atinjam cumulativamente 40 MB
.
Controle de acesso
O usuário que executa sp.processor.sample()
deve ter a função atlasAdmin
.
Exemplo
O exemplo a seguir mostra uma resposta esperada ao chamar sp.solarDemo.sample()
para obter amostras de um processador de fluxo chamado solarDemo
:
sp.solarDemo.sample()
{ _id: { device_id: 'device_5' }, max_temp: 8, max_watts: 66, min_watts: 66, avg_watts: 66, median_watts: 66, _stream_meta: { windowStartTimestamp: ISODate('2024-03-19T22:09:10.000Z'), windowEndTimestamp: ISODate('2024-03-19T22:09:20.000Z') } } { _id: { device_id: 'device_0' }, max_temp: 18, max_watts: 210, min_watts: 68, avg_watts: 157, median_watts: 193, _stream_meta: { windowStartTimestamp: ISODate('2024-03-19T22:09:10.000Z'), windowEndTimestamp: ISODate('2024-03-19T22:09:20.000Z') } } { _id: { device_id: 'device_10' }, max_temp: 21, max_watts: 128, min_watts: 4, avg_watts: 66, median_watts: 4, _stream_meta: { windowStartTimestamp: ISODate('2024-03-19T22:09:10.000Z'), windowEndTimestamp: ISODate('2024-03-19T22:09:20.000Z') } } { _id: { device_id: 'device_9' }, max_temp: 10, max_watts: 227, min_watts: 66, avg_watts: 131.4, median_watts: 108, _stream_meta: { windowStartTimestamp: ISODate('2024-03-19T22:09:10.000Z'), windowEndTimestamp: ISODate('2024-03-19T22:09:20.000Z') } }