Definición
Nuevo en la versión 7.0:
Devuelve documentos para cada procesador de flujo con nombre en el espacio de trabajo de procesamiento de flujo actual. Cada documento proporciona información descriptiva, incluyendo el nombre, el estado actual y la canalización del procesador de flujo.
Compatibilidad
Este método es compatible con los espacios de trabajo de procesamiento de flujos de Atlas.
Sintaxis
El método sp.listStreamProcessors() tiene la siguiente sintaxis:
sp.listStreamProcessors( { <filter> } )
Campos de comandos
sp.listStreamProcessors() toma estos campos:
Campo | Tipo | Necesidad | Descripción |
|---|---|---|---|
| Documento | Opcional | Documento que especifica qué campos se deben filtrar en los procesadores de flujo. Si proporciona un filtro, el comando solo devolverá aquellos procesadores que coincidan con los valores de todos los campos que se especifique. |
Comportamiento
sp.listStreamProcessors() devuelve documentos que describen todos los procesadores de flujo nombrados en el espacio de trabajo actual de stream processing a STDOUT.
Control de acceso
El usuario que ejecuta sp.listStreamProcessors() debe tener el rol atlasAdmin.
Ejemplo
El siguiente ejemplo muestra una respuesta esperada de sp.listStreamProcessors() cuando el comando se llama sin ningún filtro:
sp.listStreamProcessors()
1 { 2 id: '0135', 3 name: "proc01", 4 last_modified: ISODate("2023-03-20T20:15:54.601Z"), 5 state: "RUNNING", 6 error_msg: '', 7 pipeline: [ 8 { 9 $source: { 10 connectionName: "myKafka", 11 topic: "stuff" 12 } 13 }, 14 { 15 $match: { 16 temperature: 46 17 } 18 }, 19 { 20 $emit: { 21 connectionName: "mySink", 22 topic: "output", 23 } 24 } 25 ], 26 lastStateChange: ISODate("2023-03-20T20:15:59.442Z") 27 }, 28 { 29 id: '0218', 30 name: "proc02", 31 last_modified: ISODate("2023-03-21T20:17:33.601Z"), 32 state: "STOPPED", 33 error_msg: '', 34 pipeline: [ 35 { 36 $source: { 37 connectionName: "myKafka", 38 topic: "things" 39 } 40 }, 41 { 42 $match: { 43 temperature: 41 44 } 45 }, 46 { 47 $emit: { 48 connectionName: "mySink", 49 topic: "results", 50 } 51 } 52 ], 53 lastStateChange: ISODate("2023-03-21T20:18:26.139Z") 54 }
El siguiente ejemplo muestra una respuesta esperada si se invoca sp.listStreamProcessors() filtrando solo aquellos procesadores de flujo con un state de running.
sp.listStreamProcessors({"state": "running"})
1 { 2 id: '0135', 3 name: "proc01", 4 last_modified: ISODate("2023-03-20T20:15:54.601Z"), 5 state: "RUNNING", 6 error_msg: '', 7 pipeline: [ 8 { 9 $source: { 10 connectionName: "myKafka", 11 topic: "stuff" 12 } 13 }, 14 { 15 $match: { 16 temperature: 46 17 } 18 }, 19 { 20 $emit: { 21 connectionName: "mySink", 22 topic: "output", 23 } 24 } 25 ], 26 lastStateChange: ISODate("2023-03-20T20:15:59.442Z") 27 }