system-streams
시스템에 등록된 스트림 쿼리 목록과 상태를 조회합니다.
명령어 속성
| 항목 | 설명 |
|---|---|
| 명령어 유형 | 드라이버 쿼리 |
| 필요 권한 | 클러스터 관리자 |
| 라이선스 사용량 | 집계 안 함 |
| 병렬 실행 | 미지원 |
| 분산 실행 | 미지원 |
문법
system-streams
출력 필드
| 필드 | 타입 | 설명 |
|---|---|---|
| source_type | 문자열 | 데이터 원본 유형 (logger, table, stream 중 하나) |
| name | 문자열 | 스트림 쿼리 이름 |
| running | 불리언 | 실행 중 여부 (true: 실행 중, false: 중지) |
| enabled | 불리언 | 활성화 여부 (true: 활성화, false: 비활성화) |
| async | 불리언 | 비동기 모드 여부 (true: 비동기, false: 동기) |
| error_code | 문자열 | 마지막 오류 코드. 오류가 없으면 null을 반환합니다. |
| error_msg | 문자열 | 마지막 오류 메시지. 오류가 없으면 null을 반환합니다. |
| description | 문자열 | 스트림 쿼리에 대한 설명 |
| interval | 32비트 정수 | 리프레시 주기 (단위: 초). 0이면 무한대를 의미하며, 스트림 가능한 명령어만 사용할 수 있습니다. |
| query_string | 문자열 | 쿼리 문자열 |
| input_count | 64비트 정수 | 입력 레코드 건수 |
| output_count | 64비트 정수 | 출력 레코드 건수 |
| last_input_at | 날짜 | 마지막 입력 시각. 입력이 없으면 null을 반환합니다. |
| last_output_at | 날짜 | 마지막 출력 시각. 출력이 없으면 null을 반환합니다. |
| owner | 문자열 | 스트림 쿼리를 생성한 계정 이름 |
| created_at | 날짜 | 생성 일시 |
| modified_at | 날짜 | 수정 일시 |
| last_refresh_at | 날짜 | 마지막 리프레시 시각 |
| last_count | 64비트 정수 | 마지막 실행 시 처리된 레코드 건수 |
| last_time | 64비트 정수 | 마지막 실행 소요 시간 (단위: 나노초) |
| total_count | 64비트 정수 | 누적 처리 레코드 건수 |
| total_time | 64비트 정수 | 누적 처리 소요 시간 (단위: 나노초) |
| max_count | 64비트 정수 | 단일 실행 최대 처리 레코드 건수 |
| max_time | 64비트 정수 | 단일 실행 최대 소요 시간 (단위: 나노초) |
| input_tables | 배열 | 입력 테이블 이름 목록 |
| input_loggers | 배열 | 입력 수집기 이름 목록 |
| input_streams | 배열 | 입력 스트림 쿼리 이름 목록 |
오류 코드
파싱 오류
| 오류 코드 | 메시지 | 설명 |
|---|---|---|
| 95020 | 읽기 권한이 없습니다. 클러스터 관리자 권한이 필요합니다. | 클러스터 관리자 권한이 없는 계정이 실행한 경우 |
런타임 오류
해당 사항 없음
설명
system-streams 명령어는 시스템에 등록된 스트림 쿼리의 목록과 상태를 조회합니다. 스트림 쿼리의 이름, 실행 상태, 입출력 건수, 성능 카운터 등의 정보를 확인할 수 있습니다.
이 명령어를 실행하려면 클러스터 관리자 권한이 필요합니다. 관리자가 아닌 계정으로 실행하면 오류 코드 95020이 발생합니다.
source_type 필드는 스트림 쿼리의 데이터 원본 유형을 나타냅니다. logger는 수집기, table은 테이블, stream은 다른 스트림 쿼리를 데이터 원본으로 사용하는 것을 의미합니다.
성능 카운터(last_count, last_time, total_count, total_time, max_count, max_time) 필드는 스트림 쿼리의 성능 통계가 수집된 경우에만 값이 반환됩니다.
사용 예
-
스트림 쿼리 전체 목록 조회
system-streams -
실행 중인 스트림 쿼리만 조회
system-streams | search running == true -
데이터 원본 유형별 스트림 쿼리 수 집계
system-streams | stats count by source_type -
오류가 발생한 스트림 쿼리 조회
system-streams | search isnotnull(error_code)
호환성
system-streams 명령어는 소나 4.0 이전 버전부터 제공되었습니다.