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

Definición

sp.processor.sample()

Devuelve arreglos de resultados muestreados de un Procesador de flujos actualmente en ejecución en el Workspace de procesamiento de flujos actual.

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 con Atlas Stream Processing Workspaces.

Sintaxis

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

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 rol atlasAdmin.

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