vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-05-01 00:19:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Adds MySQL support for traffic profiles

Browse source 
Traffic profile information is dumped to MySQL.
This commit is contained in:
Simone Mainardi 2015-11-10 11:36:55 +01:00
parent 83574e1a9d
commit 71b390ec47
3 changed files with 55 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

13
scripts/lua/modules/db_utils.lua
View file

@ -35,7 +35,7 @@ end
--- ====================================================================
function getInterfaceTopFlows(interface_id, version, host, l7proto, l4proto, port, info, begin_epoch, end_epoch, offset, max_num_flows, sort_column, sort_order)
function getInterfaceTopFlows(interface_id, version, host_or_profile, l7proto, l4proto, port, info, begin_epoch, end_epoch, offset, max_num_flows, sort_column, sort_order)
-- CONVERT(UNCOMPRESS(JSON) USING 'utf8') AS JSON
if(version == 4) then
@ -51,13 +51,16 @@ function getInterfaceTopFlows(interface_id, version, host, l7proto, l4proto, por
if(port ~= "") then follow = follow .." AND (L4_SRC_PORT="..port.." OR L4_DST_PORT="..port..")" end
if(info ~= "") then follow = follow .." AND (INFO='"..info.."')" end
if((host ~= nil) and (host ~= "")) then
if host_or_profile ~= nil and host_or_profile ~= "" and string.starts(host_or_profile, 'profile:') then
host_or_profile = string.gsub(host_or_profile, 'profile:', '')
follow = follow .. " AND (PROFILE='"..host_or_profile.."') "
elseif host_or_profile ~= nil and host_or_profile ~= "" then
if(version == 4) then
rsp = expandIpV4Network(host)
rsp = expandIpV4Network(host_or_profile)
follow = follow .." AND (((IP_SRC_ADDR>="..rsp[1]..") AND (IP_SRC_ADDR <= "..rsp[2].."))"
follow = follow .." OR ((IP_DST_ADDR>="..rsp[1]..") AND (IP_DST_ADDR <= "..rsp[2]..")))"
else
follow = follow .." AND (IP_SRC_ADDR='"..host.."' OR IP_DST_ADDR='"..host.."')"
follow = follow .." AND (IP_SRC_ADDR='"..host_or_profile.."' OR IP_DST_ADDR='"..host_or_profile.."')"
end
end
@ -65,8 +68,6 @@ function getInterfaceTopFlows(interface_id, version, host, l7proto, l4proto, por
sql = sql .. follow
-- io.write(sql.."\n")
if(db_debug == true) then io.write(sql.."\n") end
res = interface.execSQLQuery(sql)