start.processor.sample() (método mongosh)

Definição

sp.processor.sample()

Retorna matrizes de resultados amostrados de um processador de fluxo atualmente em execução no espaço de trabalho de processamento de fluxo atual.

Você só pode invocar este comando enquanto estiver conectado a um espaço de trabalho de processamento de fluxo.

Este comando requer mongosh versão ≥ 2.0.

Compatibilidade

Esse método é suportado em Atlas Stream Processing Workspaces.

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
}
{
  _id: {
    device_id: 'device_0'
  },
  max_temp: 18,
  max_watts: 210,
  min_watts: 68,
  avg_watts: 157,
  median_watts: 193
}
{
  _id: {
    device_id: 'device_10'
  },
  max_temp: 21,
  max_watts: 128,
  min_watts: 4,
  avg_watts: 66,
  median_watts: 4
}
{
  _id: {
    device_id: 'device_9'
  },
  max_temp: 10,
  max_watts: 227,
  min_watts: 66,
  avg_watts: 131.4,
  median_watts: 108
}

Saiba mais

• managed processadores de fluxo