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

Definição

sp.processor.sample()

Retorna arrays de resultados de amostras de um Stream Processor atualmente em execução no Stream Processing Workspaceatual.

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

Este comando requer mongosh versão ≥ 2.0.

Compatibilidade

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

Sintaxe

The sp.processor.sample() method has the following syntax:

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 o 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