vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-04-29 07:29:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Fix Manage Data / Delete Host Data with ClickHouse

Browse source
This commit is contained in:
Alfredo Cardigliano 2022-10-31 15:59:10 +01:00
parent 324cf1b72b
commit fd4fde2e24
1 changed files with 26 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

31
scripts/lua/modules/delete_data_utils.lua
View file

@ -98,11 +98,32 @@ end
local function delete_host_mysql_flows(interface_id, host_info)
local status = "OK"
local addr = host_info["host"]
local vlan = host_info["vlan"] or 0
local q
if ntop.getPrefs()["is_dump_flows_to_mysql_enabled"] then
local addr = host_info["host"]
local vlan = host_info["vlan"] or 0
local q
if ntop.isClickHouseEnabled() then
local historical_flow_utils = require "historical_flow_utils"
local where_clause
if isIPv4(addr) then
where_clause = string.format("(IPV4_SRC_ADDR = ('%s') OR IPV4_DST_ADDR = ('%s')) AND VLAN_ID = %u AND INTERFACE_ID = %d",
addr, addr, vlan, interface_id)
else
where_clause = string.format("(IPV6_SRC_ADDR = ('%s') OR IPV6_DST_ADDR = ('%s')) AND VLAN_ID = %u AND INTERFACE_ID = %d",
addr, addr, vlan, interface_id)
end
where_clause = historical_flow_utils.fixWhereTypes(where_clause)
q = string.format("ALTER TABLE `flows` DELETE WHERE %s", where_clause)
if not dry_run and q then
interface.execSQLQuery(q)
end
elseif ntop.getPrefs()["is_dump_flows_to_mysql_enabled"] then
if isIPv4(addr) then
q = string.format("DELETE FROM %s WHERE (IP_SRC_ADDR = INET_ATON('%s') OR IP_DST_ADDR = INET_ATON('%s')) AND VLAN_ID = %u and INTERFACE_ID = %d",
@ -113,7 +134,7 @@ local function delete_host_mysql_flows(interface_id, host_info)
end
if not dry_run and q then
interface.execSQLQuery(q)
interface.execSQLQuery(q)
end
end