Definición
sp.listStreamProcessors()Devuelve documentos para cada 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.
Solo puedes invocar este comando mientras estés conectado a un entorno de trabajo de Stream Processing.
Este comando requiere
mongoshversión ≥ 2.0.
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 }