Definición
sp.listStreamProcessors()Devuelve documentos para cada nombre Procesador de flujo 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 de un procesador de flujo.
Solo puedes invocar este comando mientras estés conectado a un espacio de trabajo de procesamiento de flujo.
Este comando requiere
mongoshversión ≥ 2.0.
Compatibilidad
Este método es compatible con los espacios de trabajo de procesamiento de secuencias 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 los campos por los que se filtrarán los procesadores de flujo. Si se proporciona un filtro, el comando solo devolverá los procesadores que coincidan con los valores de todos los campos especificados. |
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 la
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 }