From 74ceabe6c2ad7615e3d62c2cbccb93d4d25e6105 Mon Sep 17 00:00:00 2001 From: houjinchuan Date: Fri, 14 Oct 2022 17:11:31 +0800 Subject: [PATCH] =?UTF-8?q?ck=20=20cn=2009=E3=80=8110=E7=89=88=E6=9C=AC?= =?UTF-8?q?=E6=9B=B4=E6=96=B0=E8=AF=AD=E5=8F=A5=E4=B8=AD=E6=B7=BB=E5=8A=A0?= =?UTF-8?q?=E5=BB=BA=E8=A1=A8=E8=AF=AD=E5=8F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../CN-22.09/clickhouse/update-09-ck.sql | 942 ++++++++++++++++++ .../CN-22.10/clickhouse/update-10-ck.sql | 384 +++++++ 2 files changed, 1326 insertions(+) create mode 100644 CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql diff --git a/CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql b/CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql index eb69743..258b230 100644 --- a/CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql +++ b/CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql @@ -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()); \ No newline at end of file diff --git a/CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql b/CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql new file mode 100644 index 0000000..9028719 --- /dev/null +++ b/CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql @@ -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()); \ No newline at end of file