start.processor.sample()
Definição
Novidades na versão 7.0: Retorna matrizes de resultados amostrados de um processador defluxo , atualmente em execução na instância de processamento de fluxo atual.
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: { window: { start: ISODate('2024-03-19T22:09:10.000Z'), end: 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: { window: { start: ISODate('2024-03-19T22:09:10.000Z'), end: 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: { window: { start: ISODate('2024-03-19T22:09:10.000Z'), end: 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: { window: { start: ISODate('2024-03-19T22:09:10.000Z'), end: ISODate('2024-03-19T22:09:20.000Z') } } }