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

Move influxdb data export into driver api

Browse source
This commit is contained in:
emanuele-f 2018-08-10 15:11:35 +02:00
parent 3088773f7a
commit b2107b6f36
7 changed files with 42 additions and 46 deletions
Download patch file Download diff file Expand all files Collapse all files

39
scripts/lua/modules/callback_utils.lua
View file

@ -220,42 +220,11 @@ end
-- ########################################################
function callback_utils.uploadTSdata()
local url = ntop.getPref("ntopng.prefs.ts_post_data_url")
local dbname = ntop.getPref("ntopng.prefs.influx_dbname")
local driver = ntop.getPref("ntopng.prefs.timeseries_driver")
if((url == nil) or (url == "") or (driver ~= "influxdb")) then
return
end
while(true) do
local name_id = ntop.lpopCache("ntopng.influx_file_queue")
local ret
if((name_id == nil) or (name_id == "")) then
break
end
if(tonumber(name_id) == nil) then
print("[ERROR] Invalid name "..name_id.."\n")
break
end
local fname = os_utils.fixPath(dirs.workingdir .. "/" .. getInterfaceId(ifname) .. "/ts_export/" .. name_id)
-- Delete the file after POST
local delete_file_after_post = true
ret = ntop.postHTTPTextFile("", "", url .. "/write?db=" .. dbname, fname, delete_file_after_post, 5 --[[ timeout ]])
--print(fname .. "\n")
if(ret ~= true) then
print("[ERROR] POST of "..fname.." failed\n")
-- delete the file manually
os.remove(fname)
break
end
local ts_utils = require("ts_utils_core")
local drivers = ts_utils.listActiveDrivers()
for _, driver in ipairs(drivers) do
driver:export()
end
end
-- ########################################################