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

Prevents InfluxDB dropped points alerts from being triggered too often

Browse source
This commit is contained in:
Simone Mainardi 2019-06-28 18:36:42 +02:00
parent 14d5675212
commit 9a5297f0d5
2 changed files with 20 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

29
scripts/lua/modules/timeseries/drivers/influxdb.lua
View file

@ -20,6 +20,7 @@ require("ntop_utils")
local INFLUX_QUERY_TIMEMOUT_SEC = 5
local INFLUX_MAX_EXPORT_QUEUE_LEN = 200
local INFLUX_KEY_PREFIX = "ntopng.cache.ifid_%i."
local INFLUX_EXPORT_QUEUE = "ntopng.influx_file_queue"
local MIN_INFLUXDB_SUPPORTED_VERSION = "1.5.1"
local FIRST_AGGREGATION_TIME_KEY = "ntopng.prefs.influxdb.first_aggregation_time"
@ -702,8 +703,6 @@ function driver:_exportTsFile(fname)
return rv
end
local INFLUX_KEY_PREFIX = "ntopng.cache.ifid_%i."
-- ##############################################
local function get_dropped_points_key(ifid)
@ -789,16 +788,24 @@ end
-- ##############################################
function driver:_droppedExportablesAlert()
local influx_alert = alerts:newAlert({
entity = "influx_db",
type = "influxdb_dropped_points",
severity = "error",
periodicity = "min",
})
function driver:_droppedExportablesAlert()
local alert_periodicity = 60
local k = "ntopng.cache.influxdb_dropped_points_alert_triggered"
local msg = droppedPointsErrorMsg(self.url)
influx_alert:trigger(self.url, msg)
if ntop.getCache(k) ~= "1" then
local influx_alert = alerts:newAlert({
entity = "influx_db",
type = "influxdb_dropped_points",
severity = "error",
periodicity = alert_periodicity,
})
local msg = droppedPointsErrorMsg(self.url)
influx_alert:trigger(self.url, msg)
-- Just to avoid doing :trigger too often
ntop.setCache(k, "1", alert_periodicity / 2)
end
end
-- ##############################################