sp.listStreamProcessors()
정의
구문
sp.listStreamProcessors() 메서드의 구문은 다음과 같습니다.
sp.listStreamProcessors( { <filter> } )
명령 필드
sp.listStreamProcessors() 는 다음 필드를 사용합니다.
필드 | 유형 | 필요성 | 설명 |
|---|---|---|---|
filter | 문서 | 옵션 | 스트림 프로세서를 필터링할 필드를 지정하는 문서입니다. 필터를 제공하면 명령은 지정한 모든 필드의 값과 일치하는 프로세서만 반환합니다. |
행동
sp.listStreamProcessors() 현재 Atlas Stream Processing 인스턴스의 명명된 모든 스트림 프로세서를 설명하는 문서를 STDOUT 으)로 반환합니다.
액세스 제어
sp.listStreamProcessors() 을(를) 실행하는 사용자에게는 atlasAdmin 역할이 있어야 합니다.
예제
다음 예에서는 필터 없이 명령이 호출될 때 sp.listStreamProcessors() 의 예상 응답을 보여줍니다.
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 }
다음 예에서는 state 가 running 인 스트림 프로세서에 대해서만 sp.listStreamProcessors() 필터링을 호출하는 경우 예상되는 응답을 보여줍니다.
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 }