CN 23.12 update CK 修改基础预聚合表字段，新增metric_subscriber表和metric_subscriber_app表
This commit is contained in:
houjinchuan
753
CN发布版本更新记录/CN-23.12/clickhouse/update-23.12-ck.sql
Normal file
753
CN发布版本更新记录/CN-23.12/clickhouse/update-23.12-ck.sql
Normal file
@@ -0,0 +1,753 @@
|
||||
set distributed_ddl_task_timeout = 180;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_ip_local on cluster ck_cluster
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_ip on cluster ck_cluster
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_ip on cluster ck_query
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_region_local on cluster ck_cluster
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_region on cluster ck_cluster
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_region on cluster ck_query
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_asn_local on cluster ck_cluster
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_asn on cluster ck_cluster
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_asn on cluster ck_query
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_domain_local on cluster ck_cluster
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_domain on cluster ck_cluster
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_domain on cluster ck_query
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_link_local on cluster ck_cluster
|
||||
rename column IF EXISTS common_out_link_id TO out_link_id,
|
||||
rename column IF EXISTS common_in_link_id TO in_link_id,
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_link on cluster ck_cluster
|
||||
rename column IF EXISTS common_out_link_id TO out_link_id,
|
||||
rename column IF EXISTS common_in_link_id TO in_link_id,
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
ALTER table cyber_narrator_galaxy.metric_link on cluster ck_query
|
||||
rename column IF EXISTS common_out_link_id TO out_link_id,
|
||||
rename column IF EXISTS common_in_link_id TO in_link_id,
|
||||
rename column IF EXISTS common_c2s_pkt_num TO sent_pkts,
|
||||
rename column IF EXISTS common_c2s_byte_num TO sent_bytes,
|
||||
rename column IF EXISTS common_s2c_pkt_num TO received_pkts,
|
||||
rename column IF EXISTS common_s2c_byte_num TO received_bytes,
|
||||
rename column IF EXISTS common_sessions TO sessions,
|
||||
rename column IF EXISTS c2s_tcp_lostlen_ratio TO tcp_c2s_lost_bytes_ratio,
|
||||
rename column IF EXISTS s2c_tcp_lostlen_ratio TO tcp_s2c_lost_bytes_ratio,
|
||||
rename column IF EXISTS tcp_lostlen_ratio TO tcp_lost_bytes_ratio,
|
||||
rename column IF EXISTS c2s_tcp_unorder_num_ratio TO tcp_c2s_o3_pkts_ratio,
|
||||
rename column IF EXISTS s2c_tcp_unorder_num_ratio TO tcp_s2c_o3_pkts_ratio,
|
||||
rename column IF EXISTS tcp_unorder_num_ratio TO tcp_o3_pkts_ratio,
|
||||
rename column IF EXISTS c2s_byte_retrans_ratio TO tcp_c2s_rtx_bytes_ratio,
|
||||
rename column IF EXISTS s2c_byte_retrans_ratio TO tcp_s2c_rtx_bytes_ratio,
|
||||
rename column IF EXISTS byte_retrans_ratio TO tcp_rtx_bytes_ratio,
|
||||
rename column IF EXISTS c2s_pkt_retrans_ratio TO tcp_c2s_rtx_pkts_ratio,
|
||||
rename column IF EXISTS s2c_pkt_retrans_ratio TO tcp_s2c_rtx_pkts_ratio,
|
||||
rename column IF EXISTS pkt_retrans_ratio TO tcp_rtx_pkts_ratio,
|
||||
rename column IF EXISTS avg_establish_latency_ms TO avg_tcp_rtt_ms,
|
||||
rename column IF EXISTS avg_ssl_con_latency_ms TO avg_ssl_handshake_latency_ms;
|
||||
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application_local ON CLUSTER ck_cluster (
|
||||
app String,
|
||||
app_category String,
|
||||
app_subcategory String,
|
||||
app_company String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,app,app_category,app_subcategory,app_company) SETTINGS index_granularity = 8192;
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application ON CLUSTER ck_cluster (
|
||||
app String,
|
||||
app_category String,
|
||||
app_subcategory String,
|
||||
app_company String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(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 (
|
||||
app String,
|
||||
app_category String,
|
||||
app_subcategory String,
|
||||
app_company String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_application_local', rand());
|
||||
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol_local ON CLUSTER ck_cluster (
|
||||
l7_protocol String,
|
||||
server_port Int64,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,l7_protocol,server_port) SETTINGS index_granularity = 8192;
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol ON CLUSTER ck_cluster (
|
||||
l7_protocol String,
|
||||
server_port Int64,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(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 (
|
||||
l7_protocol String,
|
||||
server_port Int64,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_protocol_local', rand());
|
||||
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_subscriber_local ON CLUSTER ck_cluster (
|
||||
subscriber_id String,
|
||||
imei String,
|
||||
imsi String,
|
||||
phone_number String,
|
||||
apn String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,subscriber_id) SETTINGS index_granularity = 8192;
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_subscriber ON CLUSTER ck_cluster (
|
||||
subscriber_id String,
|
||||
imei String,
|
||||
imsi String,
|
||||
phone_number String,
|
||||
apn String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_subscriber_local', rand());
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_subscriber ON CLUSTER ck_query (
|
||||
subscriber_id String,
|
||||
imei String,
|
||||
imsi String,
|
||||
phone_number String,
|
||||
apn String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_subscriber_local', rand());
|
||||
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_subscriber_app_local ON CLUSTER ck_cluster (
|
||||
subscriber_id String,
|
||||
app String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,subscriber_id) SETTINGS index_granularity = 8192;
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_subscriber_app ON CLUSTER ck_cluster (
|
||||
subscriber_id String,
|
||||
app String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_subscriber_app_local', rand());
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_subscriber_app ON CLUSTER ck_query (
|
||||
subscriber_id String,
|
||||
app String,
|
||||
stat_time Int64,
|
||||
sent_pkts Int64,
|
||||
sent_bytes Int64,
|
||||
received_pkts Int64,
|
||||
received_bytes Int64,
|
||||
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,
|
||||
tcp_c2s_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_lost_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_o3_pkts_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_rtx_bytes_ratio Nullable(Float64),
|
||||
tcp_c2s_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_s2c_rtx_pkts_ratio Nullable(Float64),
|
||||
tcp_rtx_pkts_ratio Nullable(Float64),
|
||||
avg_tcp_rtt_ms Nullable(Float64),
|
||||
avg_http_response_latency_ms Nullable(Float64),
|
||||
avg_ssl_handshake_latency_ms Nullable(Float64)
|
||||
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_subscriber_app_local', rand());
|
||||
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user