Definição
Novidades na versão 7.0: Retorna documentos para cada processador de fluxo nomeado no espaço de trabalho de processamento de fluxo atual. Cada documento fornece informações descritivas, incluindo o nome, estado atual e pipeline de um processador de stream.
Compatibilidade
Esse método é suportado em Atlas Stream Processing Workspaces.
Sintaxe
O método sp.listStreamProcessors() tem a seguinte sintaxe:
sp.listStreamProcessors( { <filter> } )
Campos de comando
sp.listStreamProcessors() usa estes campos:
Campo | Tipo | necessidade | Descrição |
|---|---|---|---|
| documento | Opcional | Documento que especifica em quais campos filtrar os processadores de stream. Se você fornecer um filtro, o comando retornará somente os processadores que correspondam aos valores para todos os campos que você especificar. |
Comportamento
sp.listStreamProcessors() retorna documentos descrevendo todos os processadores de fluxo nomeados no espaço de trabalho de stream processing atual para STDOUT.
Controle de acesso
The user running sp.listStreamProcessors() must have the atlasAdmin role.
Exemplo
O exemplo a seguir mostra uma resposta esperada do sp.listStreamProcessors() quando o comando é chamado sem nenhum 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 }
O exemplo a seguir mostra uma resposta esperada se você invocar a filtragem sp.listStreamProcessors() apenas para os processadores de fluxo com um 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 }