sp.processor.muestra() (método mongosh)

Definición

sp.processor.sample()

Devuelve arreglos de resultados muestreados de una Stream Processor en el Stream Processing Workspaceactual.

Solo puedes invocar este comando mientras estés conectado a un entorno de trabajo de Stream Processing.

Este comando requiere mongosh versión ≥ 2.0.

Compatibilidad

Este método es compatible en espacios de trabajo de Atlas Stream Processing.

Sintaxis

El método sp.processor.sample() tiene la siguiente sintaxis:

sp.processor.sample()

Campos de comandos

sp.processor.sample() no toma campos.

Comportamiento

sp.processor.sample() devuelve arreglos de resultados muestreados del procesador de flujo nombrado y actualmente en ejecución a STDOUT. Este comando se ejecuta de forma continua hasta que lo canceles usando CTRL-C, o hasta que las muestras devueltas alcancen en conjunto 40 MB.

Control de acceso

El usuario que ejecuta sp.processor.sample() debe tener el atlasAdmin rol.

Ejemplo

El siguiente ejemplo muestra una respuesta esperada al llamar a sp.solarDemo.sample() para obtener una muestra de un procesador de transmisiones llamado 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
}

Obtén más información

• Gestionar procesadores de flujo