From 2f8baa28d16eec13433038fd1ef6cc5e9197a78c Mon Sep 17 00:00:00 2001
From: wangkuan <wangkuan@geedgenetworks.com>
Date: Wed, 24 Apr 2024 13:59:58 +0800
Subject: [PATCH] =?UTF-8?q?TSG-20471=20=E6=96=B0=E5=A2=9E=E5=AD=97?=
 =?UTF-8?q?=E6=AE=B5traffic=5Flink=5Fid?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../TSG-24.05/clickhouse/{check-24.04.sql => check-24.05.sql}  | 3 ++-
 .../TSG-24.05/clickhouse/{update-24.04-ck.sql => update-24.05-ck.sql} | 3 +++
 2 files changed, 5 insertions(+), 1 deletion(-)
 rename TSG发布版本更新记录/TSG-24.05/clickhouse/{check-24.04.sql => check-24.05.sql} (98%)
 rename TSG发布版本更新记录/TSG-24.05/clickhouse/{update-24.04-ck.sql => update-24.05-ck.sql} (95%)

diff --git a/TSG发布版本更新记录/TSG-24.05/clickhouse/check-24.04.sql b/TSG发布版本更新记录/TSG-24.05/clickhouse/check-24.05.sql
similarity index 98%
rename from TSG发布版本更新记录/TSG-24.05/clickhouse/check-24.04.sql
rename to TSG发布版本更新记录/TSG-24.05/clickhouse/check-24.05.sql
index 36c9123..605c0e5 100644
--- a/TSG发布版本更新记录/TSG-24.05/clickhouse/check-24.04.sql
+++ b/TSG发布版本更新记录/TSG-24.05/clickhouse/check-24.05.sql
@@ -14,7 +14,8 @@ SELECT recv_time, log_id, decoded_as, session_id, ingestion_time, processing_tim
 FROM tsg_galaxy_v3.transaction_record where recv_time >= toUnixTimestamp('2030-01-01 00:00:00') AND recv_time <toUnixTimestamp('2030-01-01 00:00:01');
 SELECT recv_time, log_id, decoded_as, session_id, start_timestamp_ms, end_timestamp_ms, duration_ms, tcp_handshake_latency_ms, ingestion_time, processing_time, insert_time, device_id, out_link_id, in_link_id, device_tag, data_center, device_group, sled_ip, address_type, vsys_id, t_vsys_id, flags, flags_identify_info, security_rule_list, security_action, monitor_rule_list, shaping_rule_list, proxy_rule_list, statistics_rule_list, sc_rule_list, sc_rsp_raw, sc_rsp_decrypted, proxy_action, proxy_pinning_status, proxy_intercept_status, proxy_passthrough_reason, proxy_client_side_latency_ms, proxy_server_side_latency_ms, proxy_client_side_version, proxy_server_side_version, proxy_cert_verify, proxy_intercept_error, monitor_mirrored_pkts, monitor_mirrored_bytes, client_ip, client_port, client_os_desc, client_geolocation, client_country, client_super_administrative_area, client_administrative_area, client_sub_administrative_area, client_asn, subscriber_id, imei, imsi, phone_number, apn, server_ip, server_port, server_os_desc, server_geolocation, server_country, server_super_administrative_area, server_administrative_area, server_sub_administrative_area, server_asn, server_fqdn, server_domain, app_transition, app, app_debug_info, app_content, fqdn_category_list, ip_protocol, decoded_path, sip_call_id, sip_originator_description, sip_responder_description, sip_user_agent, sip_server, sip_originator_sdp_connect_ip, sip_originator_sdp_media_port, sip_originator_sdp_media_type, sip_originator_sdp_content, sip_responder_sdp_connect_ip, sip_responder_sdp_media_port, sip_responder_sdp_media_type, sip_responder_sdp_content, sip_duration_s, sip_bye, rtp_payload_type_c2s, rtp_payload_type_s2c, rtp_pcap_path, rtp_originator_dir, sent_pkts, received_pkts, sent_bytes, received_bytes, tcp_c2s_ip_fragments, tcp_s2c_ip_fragments, tcp_c2s_lost_bytes, tcp_s2c_lost_bytes, tcp_c2s_o3_pkts, tcp_s2c_o3_pkts, tcp_c2s_rtx_pkts, tcp_s2c_rtx_pkts, tcp_c2s_rtx_bytes, tcp_s2c_rtx_bytes, tcp_rtt_ms, tcp_client_isn, tcp_server_isn, packet_capture_file, in_src_mac, out_src_mac, in_dest_mac, out_dest_mac, encapsulation, dup_traffic_flag, tunnel_id_list, tunnel_endpoint_a_desc, tunnel_endpoint_b_desc
 FROM tsg_galaxy_v3.voip_record where recv_time >= toUnixTimestamp('2030-01-01 00:00:00') AND recv_time <toUnixTimestamp('2030-01-01 00:00:01');
-
+SELECT log_id, recv_time, vsys_id, timestamp_us, job_id, sled_ip, device_group, traffic_link_id, source_ip, source_port, destination_ip, destination_port, packet, packet_length, measurements
+FROM tsg_galaxy_v3.datapath_telemetry_record where recv_time >= toUnixTimestamp('2030-01-01 00:00:00') AND recv_time <toUnixTimestamp('2030-01-01 00:00:01');
 
 
     
\ No newline at end of file
diff --git a/TSG发布版本更新记录/TSG-24.05/clickhouse/update-24.04-ck.sql b/TSG发布版本更新记录/TSG-24.05/clickhouse/update-24.05-ck.sql
similarity index 95%
rename from TSG发布版本更新记录/TSG-24.05/clickhouse/update-24.04-ck.sql
rename to TSG发布版本更新记录/TSG-24.05/clickhouse/update-24.05-ck.sql
index ffda7f0..f76056c 100644
--- a/TSG发布版本更新记录/TSG-24.05/clickhouse/update-24.04-ck.sql
+++ b/TSG发布版本更新记录/TSG-24.05/clickhouse/update-24.05-ck.sql
@@ -8,6 +8,7 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record_local on clus
     job_id String,
     sled_ip String,
     device_group String,
+    traffic_link_id Int32,
     source_ip String,
     source_port Int32,
     destination_ip String,
@@ -28,6 +29,7 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record on cluster ck
     job_id String,
     sled_ip String,
     device_group String,
+    traffic_link_id Int32,
     source_ip String,
     source_port Int32,
     destination_ip String,
@@ -49,6 +51,7 @@ ENGINE = Distributed('ck_cluster',
     job_id String,
     sled_ip String,
     device_group String,
+    traffic_link_id Int32,
     source_ip String,
     source_port Int32,
     destination_ip String,