본문으로 바로가기
본문으로 바로가기

system.query_log

ClickHouse Cloud에서 쿼리하기

이 시스템 테이블의 데이터는 ClickHouse Cloud의 각 노드에 로컬로 저장됩니다. 따라서 전체 데이터를 조회하려면 clusterAllReplicas 함수를 사용해야 합니다. 자세한 내용은 여기를 참고하십시오.

설명

실행된 쿼리에 대한 메타데이터와 통계(시작 시각, 소요 시간, 오류 메시지, 리소스 사용량 및 기타 실행 세부 정보 등)를 저장합니다. 쿼리 결과 자체는 저장하지 않습니다.

서버 설정의 query_log 섹션에서 쿼리 로깅 관련 설정을 변경할 수 있습니다.

log_queries = 0 설정으로 쿼리 로깅을 비활성화할 수 있습니다. 이 테이블의 정보는 문제 해결에 중요하므로 로깅을 끄지 않을 것을 권장합니다.

데이터 플러시 주기는 query_log 서버 설정 섹션의 flush_interval_milliseconds 파라미터로 설정합니다. 플러시를 강제로 수행하려면 SYSTEM FLUSH LOGS 쿼리를 사용합니다.

ClickHouse는 이 테이블에서 데이터를 자동으로 삭제하지 않습니다. 자세한 내용은 Introduction을 참조하십시오.

system.query_log 테이블은 두 종류의 쿼리를 기록합니다.

  1. 클라이언트에서 직접 실행한 초기 쿼리
  2. 다른 쿼리(분산 쿼리 실행용)에 의해 시작된 자식 쿼리 이러한 유형의 쿼리에 대해서는 부모 쿼리에 대한 정보가 initial_* 컬럼에 표시됩니다.

각 쿼리는 상태(쿼리의 type 컬럼 참조)에 따라 query_log 테이블에 하나 또는 두 개의 행을 생성합니다.

  1. 쿼리 실행이 성공하면 QueryStartQueryFinish 타입의 두 행이 생성됩니다.
  2. 쿼리 처리 중에 오류가 발생하면 QueryStartExceptionWhileProcessing 타입의 두 이벤트가 생성됩니다.
  3. 쿼리를 시작하기 전에 오류가 발생하면 ExceptionBeforeStart 타입의 단일 이벤트가 생성됩니다.

query_log 테이블에 기록되는 쿼리 수를 줄이려면 log_queries_probability 설정을 사용할 수 있습니다.

서식이 지정된 쿼리를 formatted_query 컬럼에 기록하려면 log_formatted_queries 설정을 사용할 수 있습니다.

컬럼

  • hostname (LowCardinality(String)) — 쿼리를 실행하는 서버의 호스트명입니다.
  • type (Enum8('QueryStart' = 1, 'QueryFinish' = 2, 'ExceptionBeforeStart' = 3, 'ExceptionWhileProcessing' = 4)) — 쿼리 실행 시 발생한 이벤트의 유형입니다. 값: QueryStart — 쿼리 실행이 성공적으로 시작됨, QueryFinish — 쿼리 실행이 성공적으로 완료됨, ExceptionBeforeStart — 쿼리 실행 시작 전 예외, ExceptionWhileProcessing — 쿼리 실행 중 예외.
  • event_date (Date) — 쿼리 시작일입니다.
  • event_time (DateTime) — 쿼리 시작 시각입니다.
  • event_time_microseconds (DateTime64(6)) — 마이크로초 단위까지 정밀하게 기록된 쿼리 시작 시간입니다.
  • query_start_time (DateTime) — 쿼리 실행이 시작된 시간입니다.
  • query_start_time_microseconds (DateTime64(6)) — 마이크로초 단위 정밀도의 쿼리 실행 시작 시간입니다.
  • query_duration_ms (UInt64) — 쿼리 실행에 걸린 시간(밀리초)입니다.
  • read_rows (UInt64) — 쿼리에 참여한 모든 테이블과 테이블 함수에서 읽은 총 행 수입니다. 여기에는 일반 서브쿼리와 IN 및 JOIN용 서브쿼리가 포함됩니다. 분산 쿼리의 경우 read_rows에는 모든 레플리카에서 읽은 총 행 수가 포함됩니다. 각 레플리카는 자체 read_rows 값을 전송하며, 쿼리의 시작 서버는 수신한 모든 값과 로컬 값을 합산합니다. 캐시의 크기는 이 값에 영향을 주지 않습니다.
  • read_bytes (UInt64) — 쿼리에 참여한 모든 테이블과 테이블 함수에서 읽은 총 바이트 수입니다. 여기에는 일반적인 서브쿼리와 IN 및 JOIN용 서브쿼리가 포함됩니다. 분산 쿼리의 경우, read_bytes에는 모든 레플리카에서 읽은 총 행 수가 포함됩니다. 각 레플리카는 자체 read_bytes 값을 전송하며, 쿼리를 시작한 서버는 수신한 모든 값과 로컬 값을 합산합니다. 캐시 볼륨은 이 값에 영향을 주지 않습니다.
  • written_rows (UInt64) — INSERT 쿼리에서는 기록된 행 수를 나타냅니다. 다른 쿼리에서는 컬럼 값이 0입니다.
  • written_bytes (UInt64) — INSERT 쿼리에서는 기록된 바이트 수(비압축)를 나타냅니다. 다른 쿼리에서는 컬럼 값이 0입니다.
  • result_rows (UInt64) — SELECT 쿼리 결과의 행 수 또는 INSERT 쿼리의 행 수입니다.
  • result_bytes (UInt64) — 쿼리 결과 저장에 사용되는 RAM 용량(바이트)입니다.
  • memory_usage (UInt64) — 쿼리의 메모리 사용량입니다.
  • current_database (LowCardinality(String)) — 현재 데이터베이스 이름입니다.
  • query (String) — 쿼리 문자열입니다.
  • formatted_query (String) — 서식이 지정된 쿼리 문자열.
  • normalized_query_hash (UInt64) — 리터럴 값만 다른 쿼리에는 동일한 숫자 해시 값입니다.
  • query_kind (LowCardinality(String)) — 쿼리 유형.
  • databases (Array(LowCardinality(String))) — 쿼리에 포함된 데이터베이스 이름입니다.
  • tables (Array(LowCardinality(String))) — 쿼리에 포함된 테이블 이름입니다.
  • columns (Array(LowCardinality(String))) — 쿼리에 포함된 컬럼의 이름입니다.
  • partitions (Array(LowCardinality(String))) — 쿼리에 포함된 파티션 이름입니다.
  • projections (Array(LowCardinality(String))) — 쿼리 실행 중 사용되는 프로젝션의 이름입니다.
  • views (Array(LowCardinality(String))) — 쿼리에 포함된 (구체화된 또는 라이브) 뷰의 이름입니다.
  • exception_code (Int32) — 예외 코드입니다.
  • exception (String) — 예외 메시지.
  • stack_trace (String) — 스택 트레이스입니다. 쿼리가 성공적으로 완료된 경우 빈 문자열입니다.
  • is_initial_query (UInt8) — 쿼리 유형입니다. 가능한 값: 1 — 클라이언트가 시작한 쿼리입니다. 0 — 분산 쿼리 실행의 일부로 다른 쿼리가 시작한 쿼리입니다.
  • connection_address (IPv6) — 연결이 이루어진 클라이언트의 IP 주소입니다. 프록시를 통해 연결된 경우 이 값은 프록시의 주소입니다.
  • connection_port (UInt16) — 연결이 설정된 클라이언트 포트입니다. 프록시를 통해 연결된 경우 프록시의 포트가 됩니다.
  • user (LowCardinality(String)) — 현재 쿼리를 실행한 사용자의 이름입니다.
  • query_id (String) — 쿼리 ID입니다.
  • address (IPv6) — 쿼리를 수행할 때 사용된 IP 주소입니다. 프록시를 통해 연결되어 있고 auth_use_forwarded_address가 설정된 경우, 이 값은 프록시 주소가 아니라 클라이언트 주소가 됩니다.
  • port (UInt16) — 쿼리를 실행하는 데 사용된 클라이언트 포트입니다. 프록시를 통해 연결되어 있고 auth_use_forwarded_address가 설정된 경우, 이 값은 프록시 포트가 아니라 클라이언트 포트입니다.
  • initial_user (LowCardinality(String)) — 분산 쿼리 실행 시 초기 쿼리를 실행한 사용자의 이름입니다.
  • initial_query_id (String) — 초기 쿼리의 ID(분산 쿼리 실행 시 사용).
  • initial_address (IPv6) — 상위 쿼리가 실행된 IP 주소입니다.
  • initial_port (UInt16) — 부모 쿼리를 실행하는 데 사용된 클라이언트 포트입니다.
  • initial_query_start_time (DateTime) — 분산 쿼리 실행 시의 초기 쿼리 시작 시간입니다.
  • initial_query_start_time_microseconds (DateTime64(6)) — 마이크로초 단위 정밀도의 초기 쿼리 시작 시간(분산 쿼리 실행 시)입니다.
  • authenticated_user (LowCardinality(String)) — 세션에서 인증된 사용자 이름입니다.
  • interface (UInt8) — 쿼리가 시작된 인터페이스입니다. 가능한 값: 1 — TCP, 2 — HTTP.
  • is_secure (UInt8) — 쿼리가 보안 인터페이스를 통해 실행되었는지를 나타내는 플래그
  • os_user (LowCardinality(String)) — clickhouse-client를 실행하는 OS 사용자의 이름.
  • client_hostname (LowCardinality(String)) — clickhouse-client 또는 다른 TCP 클라이언트가 실행 중인 클라이언트 머신의 호스트명입니다.
  • client_name (LowCardinality(String)) — clickhouse-client 또는 기타 TCP 클라이언트의 이름입니다.
  • client_revision (UInt32) — clickhouse-client 또는 다른 TCP 클라이언트의 리비전입니다.
  • client_version_major (UInt32) — clickhouse-client 또는 다른 TCP 클라이언트의 주 버전입니다.
  • client_version_minor (UInt32) — clickhouse-client 또는 다른 TCP 클라이언트의 마이너 버전입니다.
  • client_version_patch (UInt32) — clickhouse-client 또는 다른 TCP 클라이언트 버전의 패치 부분입니다.
  • script_query_number (UInt32) — 여러 쿼리를 포함한 clickhouse-client 스크립트의 쿼리 번호입니다.
  • script_line_number (UInt32) — clickhouse-client용으로 여러 쿼리가 포함된 스크립트에서 쿼리가 시작되는 줄 번호입니다.
  • http_method (UInt8) — 쿼리를 시작한 HTTP 메서드입니다. 가능한 값: 0 — TCP 인터페이스를 통해 쿼리가 실행되었습니다, 1 — GET 메서드가 사용되었습니다, 2 — POST 메서드가 사용되었습니다.
  • http_user_agent (LowCardinality(String)) — HTTP 쿼리와 함께 전달되는 HTTP 헤더 UserAgent입니다.
  • http_referer (String) — HTTP 쿼리와 함께 전달되는 HTTP 헤더 Referer(쿼리를 보내는 페이지의 절대 주소 또는 일부 주소를 포함합니다).
  • forwarded_for (String) — HTTP 쿼리에 전달되는 HTTP 헤더 X-Forwarded-For.
  • quota_key (String) — 쿼터 설정에 지정된 쿼터 키입니다(keyed 참조).
  • distributed_depth (UInt64) — 서버 간에 쿼리가 전달된 횟수입니다.
  • revision (UInt32) — ClickHouse 개정 번호.
  • log_comment (String) — 로그 주석입니다. max_query_size를 넘지 않는 임의의 문자열로 설정할 수 있습니다. 정의되지 않은 경우 빈 문자열입니다.
  • thread_ids (Array(UInt64)) — 쿼리 실행에 참여하는 스레드 ID입니다. 이 스레드들이 반드시 동시에 실행된 것은 아닙니다.
  • peak_threads_usage (UInt64) — 쿼리 실행에 사용된 동시 스레드 수의 최댓값입니다.
  • ProfileEvents (Map(LowCardinality(String), UInt64)) — 다양한 메트릭을 나타내는 ProfileEvents입니다. 이에 대한 설명은 system.events 테이블에서 확인할 수 있습니다.
  • Settings (Map(LowCardinality(String), LowCardinality(String))) — 클라이언트가 쿼리를 실행할 때 변경된 설정입니다. 설정 변경 사항을 기록하려면 log_query_settings 매개변수를 1로 설정하십시오.
  • used_aggregate_functions (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 집계 함수의 표준 이름입니다.
  • used_aggregate_function_combinators (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 aggregate function combinator의 표준 이름입니다.
  • used_database_engines (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 데이터베이스 엔진의 표준 이름입니다.
  • used_data_type_families (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 데이터 타입 계열의 표준 이름입니다.
  • used_dictionaries (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 딕셔너리의 표준 이름입니다.
  • used_formats (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 형식의 정식 이름입니다.
  • used_functions (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 함수의 표준 이름입니다.
  • used_storages (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 스토리지의 정식 이름입니다.
  • used_table_functions (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 테이블 함수의 표준 이름입니다.
  • used_executable_user_defined_functions (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 실행형 사용자 정의 함수의 표준 이름입니다.
  • used_sql_user_defined_functions (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 SQL 사용자 정의 함수의 정식 명칭입니다.
  • used_row_policies (Array(LowCardinality(String))) — 쿼리 실행 중 사용된 행 정책의 이름 목록입니다.
  • used_privileges (Array(LowCardinality(String))) — 쿼리 실행 중 성공적으로 확인된 권한입니다.
  • missing_privileges (Array(LowCardinality(String))) — 쿼리 실행 중 누락된 권한입니다.
  • transaction_id (Tuple(UInt64, UInt64, UUID)) — 이 쿼리가 실행된 트랜잭션의 식별자입니다.
  • query_cache_usage (Enum8('Unknown' = 0, 'None' = 1, 'Write' = 2, 'Read' = 3)) — 쿼리 실행 중 쿼리 캐시 사용 여부를 나타냅니다. 값: 'Unknown' = 상태를 알 수 없음, 'None' = 쿼리 결과가 쿼리 결과 캐시에 기록되지도 않았고 쿼리 결과 캐시에서 읽히지도 않았습니다, 'Write' = 쿼리 결과가 쿼리 결과 캐시에 기록되었습니다, 'Read' = 쿼리 결과가 쿼리 결과 캐시에서 읽혔습니다.
  • asynchronous_read_counters (Map(LowCardinality(String), UInt64)) — 비동기 읽기 메트릭입니다.
  • is_internal (UInt8) — 내부에서 실행되는 보조 쿼리인지 여부를 나타냅니다.

별칭:

  • ProfileEvents.NamesmapKeys(ProfileEvents)의 별칭입니다.
  • ProfileEvents.ValuesmapValues(ProfileEvents)의 별칭입니다.
  • Settings.NamesmapKeys(Settings)의 별칭입니다.
  • Settings.ValuesmapValues(Settings)의 별칭입니다.

예시

기본 예시

SELECT * FROM system.query_log WHERE type = 'QueryFinish' ORDER BY query_start_time DESC LIMIT 1 FORMAT Vertical;
Row 1:
──────
hostname:                              clickhouse.eu-central1.internal
type:                                  QueryFinish
event_date:                            2021-11-03
event_time:                            2021-11-03 16:13:54
event_time_microseconds:               2021-11-03 16:13:54.953024
query_start_time:                      2021-11-03 16:13:54
query_start_time_microseconds:         2021-11-03 16:13:54.952325
query_duration_ms:                     0
read_rows:                             69
read_bytes:                            6187
written_rows:                          0
written_bytes:                         0
result_rows:                           69
result_bytes:                          48256
memory_usage:                          0
current_database:                      default
query:                                 DESCRIBE TABLE system.query_log
formatted_query:
normalized_query_hash:                 8274064835331539124
query_kind:
databases:                             []
tables:                                []
columns:                               []
projections:                           []
views:                                 []
exception_code:                        0
exception:
stack_trace:
is_initial_query:                      1
user:                                  default
query_id:                              7c28bbbb-753b-4eba-98b1-efcbe2b9bdf6
address:                               ::ffff:127.0.0.1
port:                                  40452
initial_user:                          default
initial_query_id:                      7c28bbbb-753b-4eba-98b1-efcbe2b9bdf6
initial_address:                       ::ffff:127.0.0.1
initial_port:                          40452
initial_query_start_time:              2021-11-03 16:13:54
initial_query_start_time_microseconds: 2021-11-03 16:13:54.952325
interface:                             1
os_user:                               sevirov
client_hostname:                       clickhouse.eu-central1.internal
client_name:                           ClickHouse
client_revision:                       54449
client_version_major:                  21
client_version_minor:                  10
client_version_patch:                  1
http_method:                           0
http_user_agent:
http_referer:
forwarded_for:
quota_key:
revision:                              54456
log_comment:
thread_ids:                            [30776,31174]
ProfileEvents:                         {'Query':1,'NetworkSendElapsedMicroseconds':59,'NetworkSendBytes':2643,'SelectedRows':69,'SelectedBytes':6187,'ContextLock':9,'RWLockAcquiredReadLocks':1,'RealTimeMicroseconds':817,'UserTimeMicroseconds':427,'SystemTimeMicroseconds':212,'OSCPUVirtualTimeMicroseconds':639,'OSReadChars':894,'OSWriteChars':319}
Settings:                              {'load_balancing':'random','max_memory_usage':'10000000000'}
used_aggregate_functions:              []
used_aggregate_function_combinators:   []
used_database_engines:                 []
used_data_type_families:               []
used_dictionaries:                     []
used_formats:                          []
used_functions:                        []
used_storages:                         []
used_table_functions:                  []
used_executable_user_defined_functions:[]
used_sql_user_defined_functions:       []
used_privileges:                       []
missing_privileges:                    []
query_cache_usage:                     None

Cloud 예시

ClickHouse Cloud에서는 system.query_log가 각 노드에 로컬로 존재하므로, 모든 항목을 확인하려면 clusterAllReplicas를 통해 쿼리해야 합니다.

예를 들어, "default" 클러스터의 모든 레플리카에서 query_log 행을 집계하려면 다음과 같이 작성할 수 있습니다:

SELECT * 
FROM clusterAllReplicas('default', system.query_log)
WHERE event_time >= now() - toIntervalHour(1)
LIMIT 10
SETTINGS skip_unavailable_shards = 1;

관련 문서

  • system.query_thread_log — 이 테이블에는 각 쿼리 실행 스레드에 대한 정보가 포함되어 있습니다.