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

Definição

sp.processor.sample()

Retorna arrays de resultados de amostra de um processador de fluxo Stream Processor atualmente em execução no espaço de trabalho de Stream Processing atual Stream Processing Workspace.

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

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