From 1e3206c5ad9fd7bb7ec8d6bb7bd1ad2a59352562 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E5=AE=BD?= Date: Mon, 1 Nov 2021 03:19:49 +0000 Subject: [PATCH] =?UTF-8?q?21.11=20Clickhouse=5F=E5=BB=BA=E8=A1=A8?= =?UTF-8?q?=E8=AF=AD=E5=8F=A5=5F=E6=B5=8B=E8=AF=95=E7=8E=AF=E5=A2=83.sql?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Clickhouse_建表语句_测试环境.sql | 126 ++++++++++++++++-- 1 file changed, 112 insertions(+), 14 deletions(-) diff --git a/Clickhouse最新全量建表语句/Clickhouse_建表语句_测试环境.sql b/Clickhouse最新全量建表语句/Clickhouse_建表语句_测试环境.sql index 4f39a65..5a1887e 100644 --- a/Clickhouse最新全量建表语句/Clickhouse_建表语句_测试环境.sql +++ b/Clickhouse最新全量建表语句/Clickhouse_建表语句_测试环境.sql @@ -533,7 +533,18 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record_local ON CLUSTER rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String ) ENGINE=MergeTree PARTITION BY toYYYYMMDD(toDate(common_recv_time)) ORDER BY (common_log_id,common_data_center,common_recv_time); @@ -888,8 +899,19 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record ON CLUSTER ck_qu rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 -) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,interim_session_record_local,rand()); + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String + ) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,interim_session_record_local,rand()); CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record ON CLUSTER ck_cluster( common_recv_time Int64, @@ -1089,8 +1111,19 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record ON CLUSTER ck_cl rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 -) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,interim_session_record_local,rand()); + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String + ) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,interim_session_record_local,rand()); CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.transaction_record ON CLUSTER ck_query( @@ -1983,8 +2016,18 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.security_event_local ON CLUSTER ck_clus rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 - + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(common_recv_time)) ORDER BY (common_log_id,common_policy_id,common_recv_time); @@ -2330,7 +2373,18 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.session_record_local ON CLUSTER ck_clus rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String ) ENGINE=MergeTree PARTITION BY toYYYYMMDD(toDate(common_recv_time)) ORDER BY (common_log_id,common_data_center,common_recv_time); @@ -2836,7 +2890,18 @@ create table IF NOT EXISTS tsg_galaxy_v3.session_record ON CLUSTER ck_query ( rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String ) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,session_record_local,rand()); create table IF NOT EXISTS tsg_galaxy_v3.proxy_event ON CLUSTER ck_query ( @@ -3179,8 +3244,19 @@ create table IF NOT EXISTS tsg_galaxy_v3.security_event ON CLUSTER ck_query ( rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 -) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,security_event_local,rand()); + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String + ) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,security_event_local,rand()); create table IF NOT EXISTS tsg_galaxy_v3.sys_packet_capture_event ON CLUSTER ck_query ( common_recv_time Int64, @@ -3591,7 +3667,18 @@ create table IF NOT EXISTS tsg_galaxy_v3.session_record ON CLUSTER ck_cluster ( rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String ) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,session_record_local,rand()); create table IF NOT EXISTS tsg_galaxy_v3.proxy_event ON CLUSTER ck_cluster ( @@ -3934,8 +4021,19 @@ create table IF NOT EXISTS tsg_galaxy_v3.security_event ON CLUSTER ck_cluster ( rtp_payload_type_c2s Nullable(Int64), rtp_payload_type_s2c Nullable(Int64), rtp_pcap_path String, - rtp_originator_dir Int64 -) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,security_event_local,rand()); + rtp_originator_dir Int64, + ssh_version String, + ssh_auth_success String, + ssh_client_version String, + ssh_server_version String, + ssh_cipher_alg String, + ssh_mac_alg String, + ssh_compression_alg String, + ssh_kex_alg String, + ssh_host_key_alg String, + ssh_host_key String, + ssh_hassh String + ) ENGINE =Distributed(ck_cluster,tsg_galaxy_v3,security_event_local,rand()); create table IF NOT EXISTS tsg_galaxy_v3.sys_packet_capture_event ON CLUSTER ck_cluster ( common_recv_time Int64,