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

Add schema for in-memory engaged_host_alerts table and host_alerts_view aggregated view on ClickHouse

Browse source
This commit is contained in:
Alfredo Cardigliano 2024-11-08 12:46:41 +01:00
parent ac48c01f57
commit 7dedfa1a8c
2 changed files with 56 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

21
scripts/lua/modules/alert_store/host_alert_store.lua
View file

@ -32,7 +32,7 @@ function host_alert_store:init(args)
if ntop.isClickHouseEnabled() then
self._table_name = "host_alerts_view"
self._write_table_name = "host_alerts"
-- TODO self._engaged_write_table_name = "..."
self._engaged_write_table_name = "engaged_host_alerts"
else
self._table_name = "host_alerts_view"
self._write_table_name = "host_alerts"
@ -124,12 +124,19 @@ function host_alert_store:_build_insert_query(alert, write_table, engaged, rowid
local extra_columns = ""
local extra_values = ""
if rowid then
if ntop.isClickHouseEnabled() then
extra_columns = "rowid, "
extra_values = string.format("%u, ", rowid)
elseif ntop.isClickHouseEnabled() then
extra_columns = "rowid, "
extra_values = "generateUUIDv4(), "
if rowid then
extra_values = string.format("concat('00000000-0000-0000-0000-', toFixedString(hex(%u), 12)), ", rowid)
else
extra_values = "generateUUIDv4(), "
end
else
if rowid then
extra_columns = "rowid, "
extra_values = string.format("%u, ", rowid)
end
end
local alert_status = 0
@ -211,7 +218,7 @@ function host_alert_store:delete_engaged(alert)
local q
if ntop.isClickHouseEnabled() then
q = string.format("ALTER TABLE %s DELETE WHERE rowid = %u", tengaged_write_tabl, alert.rowid)
q = string.format("ALTER TABLE %s DELETE WHERE rowid = concat('00000000-0000-0000-0000-', toFixedString(hex(%u), 12))", engaged_write_table, alert.rowid)
else
q = string.format("DELETE FROM %s WHERE rowid = %u", engaged_write_table, alert.rowid)
end