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 role.
Ejemplo
El siguiente ejemplo muestra una respuesta esperada de sp.listStreamProcessors() cuando se llama al comando 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 invoca el filtrado sp.listStreamProcessors() solo para 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 }