Merge branch 'task/es_writeback_sleep_time' into 'master'

Writeback ES sleep time See merge request opensolutions/elastalert!7
datadope-io · Dec 12, 2019 · 8830932 · 8830932
2 parents f887dc5 + 29f9a24
commit 8830932
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/elastalert/elastalert.py b/elastalert/elastalert.py
@@ -1180,6 +1180,14 @@ def start(self):
 
             # Wait before querying again
             sleep_duration = total_seconds(next_run - datetime.datetime.utcnow())
+
+            # Write to ES info about the round of rules executed
+            body = {'@timestamp': ts_now(),
+                    'total_rules': [rule['name'] for rule in self.rules],
+                    'disabled_rules': [rule['name'] for rule in self.disabled_rules],
+                    'sleep_duration': sleep_duration}
+            self.writeback('elastalert_control', body)
+
             self.sleep_for(sleep_duration)
 
     def wait_until_responsive(self, timeout, clock=timeit.default_timer):