Definición
Novedades en la versión 7.0: Devuelve documentos para cada nombrado Stream Processor en el actual Stream Processing Workspace. Cada documento proporciona información descriptiva que incluye el nombre, el estado actual y la pipeline de un procesador de flujo.
Compatibilidad
Este método es compatible en espacios de trabajo de Atlas Stream Processing.
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
atlasAdmin rol.
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 }