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

Added initial work towards a new historical interface. In the Interfaces->name->Historical Actitivity it is now possible to see top flows when -F "mysql;...." is used

Browse source
This commit is contained in:
Luca Deri 2015-08-16 15:00:40 +02:00
parent 3b72506ab0
commit e59d699837
10 changed files with 281 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

96
scripts/lua/get_db_flows.lua Normal file
View file

@ -0,0 +1,96 @@
--
-- (C) 2013-15 - ntop.org
--
dirs = ntop.getDirs()
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
require "lua_utils"
require "graph_utils"
require "db_utils"
require "template"
sendHTTPHeader('text/html; charset=iso-8859-1')
interface.select(ifname)
ifstats = interface.getStats()
ifId = _GET["ifId"]
host = _GET["host"]
epoch = _GET["epoch"]
currentPage = _GET["currentPage"]
perPage = _GET["perPage"]
sortColumn = _GET["sortColumn"]
sortOrder = _GET["sortOrder"]
epoch_begin = _GET["epoch_begin"]
epoch_end = _GET["epoch_end"]
ip_version = 4
res = getInterfaceTopFlows(ifId, ip_version, epoch_begin, epoch_end, currentPage*perPage, perPage, sortColumn or 'BYTES', sortOrder or 'DESC')
if((res == nil) or (type(res) == "string")) then
return('{ "currentPage" : 1, "data" : [], "perPage" : 10, "sort" : [ [ "column_", "desc" ] ],"totalRows" : 24 }')
else
local rows = 0
print('{ "currentPage" : '..currentPage..', "data" : [\n')
for _,flow in pairs(res) do
local num = 0
local base = "<A HREF='"..ntop.getHttpPrefix().."/lua/pro/db_explorer.lua?ifId="..ifId.."&epoch_begin="..epoch_begin.."&epoch_end="..epoch_end
if(flow["L4_SRC_PORT"] ~= nil) then
local base_host_url = base.."&host="
local base_port_url = base.."&port="
if(flow["IPV4_SRC_ADDR"] ~= nil) then
s_k = "IPV4_SRC_ADDR"
d_k = "IPV4_DST_ADDR"
else
s_k = "IPV6_SRC_ADDR"
d_k = "IPV6_DST_ADDR"
end
if(ntop.isPro()) then
flow["CLIENT"] = base_host_url..flow[s_k] .."'>"..flow[s_k].."</A>:"..base_port_url..flow["L4_SRC_PORT"].."'>"..flow["L4_SRC_PORT"].."</A>"
flow["SERVER"] = base_host_url..flow[d_k] .."'>"..flow[d_k].."</A>:"..base_port_url..flow["L4_DST_PORT"].."'>"..flow["L4_DST_PORT"].."</A>"
flow["PROTOCOL"] = base.."&l4proto="..flow["PROTOCOL"].."'>"..l4ProtoToName(flow["PROTOCOL"]).."</A>"
flow["L7_PROTO"] = base.."&protocol="..flow["L7_PROTO"].."'>"..getApplicationLabel(interface.getnDPIProtoName(tonumber(flow["L7_PROTO"]))).."</A>"
flow["FLOW_URL"] = base.."&flow_idx="..flow["idx"].."'><span class='label label-info'>Info</span></A>"
else
flow["CLIENT"] = flow[s_k]..":"..flow["L4_SRC_PORT"]
flow["SERVER"] = flow[d_k]..":"..flow["L4_DST_PORT"]
flow["PROTOCOL"] = l4ProtoToName(flow["PROTOCOL"])
flow["L7_PROTO"] = getApplicationLabel(interface.getnDPIProtoName(tonumber(flow["L7_PROTO"])))
flow["FLOW_URL"] = ""
end
end
flow["FIRST_SWITCHED"] = formatEpoch(tonumber(flow["FIRST_SWITCHED"]))
flow["LAST_SWITCHED"] = formatEpoch(tonumber(flow["LAST_SWITCHED"]))
-- flow["BYTES"] = bytesToSize(tonumber(flow["BYTES"]))
-- flow["PACKETS"] = formatPackets(tonumber(flow["PACKETS"]))
if(rows > 0) then print(',\n') end
for k,v in pairs(flow) do
if(num == 0) then print('{ ') else print(', ') end
print('"'..k..'": "'..v..'"')
num = num + 1
end
print('}')
rows = rows + 1
end
print('\n], "perPage" : 10, "sort" : [ [ "'..sortColumn..'", "'.. sortOrder ..'" ] ],"totalRows" : 24 }')
end