Implements Clickhouse retention using partitioned alert tables

Addresses #6030
This commit is contained in:
Simone Mainardi 2021-11-11 12:27:56 +01:00
parent 995b0e8fe6
commit 37fe090a28
3 changed files with 16 additions and 16 deletions

View file

@ -783,7 +783,7 @@ function db_utils.clickhouseDeleteOldPartitions(mysql_retention)
-- Query the partitions that need to be deleted. Convert YYYYMMDD strings into integers so that
-- only relevant partitions can be queried and deleted
-- The last condition > 999999 prevents old partitions created as YYYMM to be deleted
local partitions_q = string.format("SELECT DISTINCT database, table, toUInt32(partition) drop_part FROM system.parts WHERE active AND table='flows' AND database='ntopng' AND drop_part <= %u AND drop_part > 999999", retention_yyyymmdd)
local partitions_q = string.format("SELECT DISTINCT database, table, toUInt32(partition) drop_part FROM system.parts WHERE active AND database='ntopng' AND drop_part <= %u AND drop_part > 999999", retention_yyyymmdd)
local partitions_res = interface.execSQLQuery(partitions_q)
-- Iterate queried partitions and delete them