Deferred flow alerts insertion through a redis queue. Removed alerts DB select when printing flow details.

This commit is contained in:
Alfredo Cardigliano 2019-10-31 12:53:23 +01:00
parent a19a878d59
commit d10dfc7762
9 changed files with 463 additions and 263 deletions

View file

@ -2803,9 +2803,10 @@ function processAlertNotifications(now, periodic_frequency, force_export)
message.table_name = nil
message = table.merge(message, res[1])
-- silly but necessary due to the AlertsManager::notifyFlowAlert
message.alert_entity = alert_consts.alert_entities.flow.entity_id -- silly but necessary due to the AlertsManager::notifyFlowAlert
-- Silly but necessary due to the notifyFlowAlert
message.alert_entity = alert_consts.alert_entities.flow.entity_id
message.alert_entity_val = "flow"
json_message = json.encode(message)
end