gfwleak/galaxy-deployment-updata-record
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ck cn 09、10版本更新语句中添加建表语句

Browse Source
This commit is contained in:
houjinchuan
2022-10-14 17:11:31 +08:00
parent 609dc69139
commit 74ceabe6c2
2 changed files with 1326 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

942
CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql
View File

@@ -13,3 +13,945 @@ ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add col
ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS server_zone String after client_idc_renter;
ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS server_zone String after client_idc_renter;
ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS server_zone String after client_idc_renter;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip_local ON CLUSTER ck_cluster (
ip String,
side String,
zone String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,ip) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip ON CLUSTER ck_cluster (
ip String,
side String,
zone String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_ip_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip ON CLUSTER ck_query (
ip String,
side String,
zone String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_ip_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_region_local ON CLUSTER ck_cluster (
country String,
province String,
city String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,country,province,city) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_region ON CLUSTER ck_cluster (
country String,
province String,
city String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_region_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_region ON CLUSTER ck_query (
country String,
province String,
city String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_region_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_asn_local ON CLUSTER ck_cluster (
asn String,
isp String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,asn,isp) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_asn ON CLUSTER ck_cluster (
asn String,
isp String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_asn_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_asn ON CLUSTER ck_query (
asn String,
isp String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_asn_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_idc_renter_local ON CLUSTER ck_cluster (
idc_renter String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,idc_renter) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_idc_renter ON CLUSTER ck_cluster (
idc_renter String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_idc_renter_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_idc_renter ON CLUSTER ck_query (
idc_renter String,
side String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_idc_renter_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application_local ON CLUSTER ck_cluster (
common_app_label String,
app_category String,
app_subcategory String,
app_company String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,common_app_label,app_category,app_subcategory,app_company) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application ON CLUSTER ck_cluster (
common_app_label String,
app_category String,
app_subcategory String,
app_company String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_application_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application ON CLUSTER ck_query (
common_app_label String,
app_category String,
app_subcategory String,
app_company String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_application_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_domain_local ON CLUSTER ck_cluster (
domain String,
domain_category_name String,
domain_category_group String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,domain,domain_category_name,domain_category_group) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_domain ON CLUSTER ck_cluster (
domain String,
domain_category_name String,
domain_category_group String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_domain_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_domain ON CLUSTER ck_query (
domain String,
domain_category_name String,
domain_category_group String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_domain_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_http_host_local ON CLUSTER ck_cluster (
http_host String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,http_host) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_http_host ON CLUSTER ck_cluster (
http_host String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_http_host_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_http_host ON CLUSTER ck_query (
http_host String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_http_host_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ssl_sni_local ON CLUSTER ck_cluster (
ssl_sni String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,ssl_sni) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ssl_sni ON CLUSTER ck_cluster (
ssl_sni String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_ssl_sni_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ssl_sni ON CLUSTER ck_query (
ssl_sni String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_ssl_sni_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol_local ON CLUSTER ck_cluster (
common_l7_protocol String,
common_server_port Int64,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,common_l7_protocol,common_server_port) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol ON CLUSTER ck_cluster (
common_l7_protocol String,
common_server_port Int64,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_protocol_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol ON CLUSTER ck_query (
common_l7_protocol String,
common_server_port Int64,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_protocol_local', rand());

384
CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql Normal file
View File

@@ -0,0 +1,384 @@
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_link_local ON CLUSTER ck_cluster (
client_country String,
client_province String,
client_region String,
server_country String,
server_province String,
server_region String,
common_egress_link_id Int64,
common_ingress_link_id Int64,
egress_link_direction String,
ingress_link_direction String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_link ON CLUSTER ck_cluster (
client_country String,
client_province String,
client_region String,
server_country String,
server_province String,
server_region String,
common_egress_link_id Int64,
common_ingress_link_id Int64,
egress_link_direction String,
ingress_link_direction String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_link_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_link ON CLUSTER ck_query (
client_country String,
client_province String,
client_region String,
server_country String,
server_province String,
server_region String,
common_egress_link_id Int64,
common_ingress_link_id Int64,
egress_link_direction String,
ingress_link_direction String,
stat_time Int64,
common_c2s_pkt_num Int64,
common_c2s_byte_num Int64,
common_s2c_pkt_num Int64,
common_s2c_byte_num Int64,
common_sessions Int64,
traffic_inbound_byte Int64,
traffic_inbound_pkt Int64,
traffic_outbound_byte Int64,
traffic_outbound_pkt Int64,
traffic_internal_byte Int64,
traffic_internal_pkt Int64,
traffic_through_byte Int64,
traffic_through_pkt Int64,
c2s_tcp_lostlen_ratio Float64,
s2c_tcp_lostlen_ratio Float64,
tcp_lostlen_ratio Float64,
c2s_tcp_unorder_num_ratio Float64,
s2c_tcp_unorder_num_ratio Float64,
tcp_unorder_num_ratio Float64,
c2s_byte_retrans_ratio Float64,
s2c_byte_retrans_ratio Float64,
byte_retrans_ratio Float64,
c2s_pkt_retrans_ratio Float64,
s2c_pkt_retrans_ratio Float64,
pkt_retrans_ratio Float64,
avg_establish_latency_ms Float64,
avg_http_response_latency_ms Float64,
avg_ssl_con_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_link_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_server_ip_local ON CLUSTER ck_cluster (
server_ip String,
server_country String,
server_city String,
server_isp String,
server_org String,
server_role Array(String),
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,server_ip) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_server_ip ON CLUSTER ck_cluster (
server_ip String,
server_country String,
server_city String,
server_isp String,
server_org String,
server_role Array(String),
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_server_ip_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_server_ip ON CLUSTER ck_query (
server_ip String,
server_country String,
server_city String,
server_isp String,
server_org String,
server_role Array(String),
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_server_ip_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qname_local ON CLUSTER ck_cluster (
qname String,
qname_sld String,
qname_tld String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,qname) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qname ON CLUSTER ck_cluster (
qname String,
qname_sld String,
qname_tld String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_qname_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qname ON CLUSTER ck_query (
qname String,
qname_sld String,
qname_tld String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_qname_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qtype_local ON CLUSTER ck_cluster (
qtype Int64,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,qtype) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qtype ON CLUSTER ck_cluster (
qtype Int64,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_qtype_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qtype ON CLUSTER ck_query (
qtype Int64,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_qtype_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rcode_local ON CLUSTER ck_cluster (
rcode Int64,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,rcode) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rcode ON CLUSTER ck_cluster (
rcode Int64,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rcode_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rcode ON CLUSTER ck_query (
rcode Int64,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rcode_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_a_local ON CLUSTER ck_cluster (
rr_a String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,rr_a) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_a ON CLUSTER ck_cluster (
rr_a String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_a_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_a ON CLUSTER ck_query (
rr_a String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_a_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_aaaa_local ON CLUSTER ck_cluster (
rr_aaaa String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,rr_aaaa) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_aaaa ON CLUSTER ck_cluster (
rr_aaaa String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_aaaa_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_aaaa ON CLUSTER ck_query (
rr_aaaa String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_aaaa_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname_local ON CLUSTER ck_cluster (
rr_cname String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,rr_cname) SETTINGS index_granularity = 8192;
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname ON CLUSTER ck_cluster (
rr_cname String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_cname_local', rand());
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname ON CLUSTER ck_query (
rr_cname String,
stat_time Int64,
query_num Int64,
traffic_inbound_byte Int64,
traffic_outbound_byte Int64,
internal_query_num Int64,
external_query_num Int64,
avg_response_latency_ms Float64
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_cname_local', rand());