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

23.06版本新增实体关系存储

Browse Source
This commit is contained in:
王宽
2023-06-25 02:58:00 +00:00
parent 6bd6a0ce91
commit 9a7c3cabce
1 changed files with 151 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

151
Clickhouse最新全量建表语句/Clickhouse_CN_建表语句.sql
View File

@@ -1707,3 +1707,154 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname ON CLUSTER
external_query_num Int64, external_query_num Int64,
avg_response_latency_ms Nullable(Float64) avg_response_latency_ms Nullable(Float64)
) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_cname_local', rand()); ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_cname_local', rand());
CREATE TABLE cyber_narrator_galaxy.cn_entity_relation_local on cluster ck_cluster
(
app_name String,
fqdn String,
ip String,
country String,
province String,
region String,
asn String,
create_time Int64,
update_time Int64
)
ENGINE = MergeTree
ORDER BY (common_server_ip,
common_server_port,
common_app_label,
domain)
TTL toDateTime(update_time) + toIntervalSecond(2592000),
toDateTime(update_time) + toIntervalSecond(1) GROUP BY ip,
fqdn,
app_name SET create_time = min(create_time),
update_time = max(update_time),
country = anyLast(country),
province = anyLast(province),
region = anyLast(region),
asn = anyLast(asn) ;
CREATE TABLE if not exists cyber_narrator_galaxy.cn_entity_relation on cluster ck_query
(
app_name String,
fqdn String,
ip String,
country String,
province String,
region String,
asn String,
create_time Int64,
update_time Int64
)
ENGINE = Distributed('ck_cluster',
'cyber_narrator_galaxy',
'cn_entity_relation_local',
rand());
CREATE TABLE if not exists cyber_narrator_galaxy.cn_entity_relation on cluster ck_cluster
(
app_name String,
fqdn String,
ip String,
country String,
province String,
region String,
asn String,
create_time Int64,
update_time Int64
)
ENGINE = Distributed('ck_cluster',
'cyber_narrator_galaxy',
'cn_entity_relation_local',
rand());
CREATE TABLE cyber_narrator_galaxy.cn_dynamic_info_relation_local on cluster ck_cluster
(
ip String,
l7_protocol String,
port Int64,
create_time Int64,
update_time Int64
)
ENGINE = MergeTree
ORDER BY (ip,port,l7_protocol)
TTL toDateTime(update_time) + toIntervalSecond(2592000) DELETE,
toDateTime(update_time) + toIntervalSecond(1) GROUP BY ip,port,l7_protocol
SET create_time = min(create_time),
update_time = max(update_time) ;
CREATE TABLE if not exists cyber_narrator_galaxy.cn_dynamic_info_relation on cluster ck_query
(
ip String,
l7_protocol String,
port Int64,
create_time Int64,
update_time Int64
)
ENGINE = Distributed('ck_cluster',
'cyber_narrator_galaxy',
'cn_dynamic_info_relation_local',
rand());
CREATE TABLE if not exists cyber_narrator_galaxy.cn_dynamic_info_relation on cluster ck_cluster
(
ip String,
l7_protocol String,
port Int64,
create_time Int64,
update_time Int64
)
ENGINE = Distributed('ck_cluster',
'cyber_narrator_galaxy',
'cn_dynamic_info_relation_local',
rand());
create MATERIALIZED VIEW if not exists cyber_narrator_galaxy.cn_entity_relation_view on cluster ck_cluster TO cyber_narrator_galaxy.cn_entity_relation_local
(
app_name String,
fqdn String,
ip String,
country String,
province String,
region String,
asn String,
create_time Int64,
update_time Int64
) AS
SELECT
common_app_label AS app_name,
ssl_sni AS fqdn,
common_server_ip AS ip,
anyLast(server_country) AS country,
anyLast(server_province) AS province,
anyLast(server_region) AS region,
anyLast(server_asn) AS asn,
min(c1.common_recv_time) AS create_time,
max(c1.common_recv_time) AS update_time
FROM cyber_narrator_galaxy.session_record_cn_local c1
where common_l4_protocol ='IPv4_TCP' OR common_server_port in(53,443)
GROUP BY ip,app_name,fqdn;
create MATERIALIZED VIEW if not exists cyber_narrator_galaxy.cn_dynamic_info_relation_view on cluster ck_cluster TO cyber_narrator_galaxy.cn_dynamic_info_relation_local
(
ip String,
l7_protocol String,
port Int64,
create_time Int64,
update_time Int64
) AS
SELECT
common_server_ip as ip,
common_l7_protocol as l7_protocol,
common_server_port as port,
min(c1.common_recv_time) AS create_time,
max(c1.common_recv_time) AS update_time
FROM cyber_narrator_galaxy.session_record_cn_local c1
where common_l4_protocol ='IPv4_TCP' OR common_server_port in(53,443)
GROUP BY ip,l7_protocol,port;