diff --git a/templates/elastalert/plugin.py b/templates/elastalert/plugin.py index 43c3c022de9e91ea61e1bdad0049d118f5f109a6..8116bd91d4272e80f22732f6f5a6c815860d7c97 100644 --- a/templates/elastalert/plugin.py +++ b/templates/elastalert/plugin.py @@ -1,3 +1,4 @@ +import json import logging from alerta.plugins import PluginBase @@ -14,6 +15,10 @@ class Elastalert(PluginBase): super().__init__() def pre_receive(self, alert, **kwargs): + if alert.service.pop() == 'elastalert': + if alert.raw_data.find('\nnew_value: [\n \"up\"\n]') > 0: + alert.severity = 'normal' + alert.status = 'closed' return alert def post_receive(self, alert, **kwargs): diff --git a/templates/elastalert/setup.py b/templates/elastalert/setup.py index 189306c5edda47bb9d77e6fb47a72db4b6f492ca..b7fd2fa9f11b42fb295a628227e6e4335972e2f9 100644 --- a/templates/elastalert/setup.py +++ b/templates/elastalert/setup.py @@ -12,8 +12,10 @@ setup( author='Jürgen Haas', author_email='juergen.haas@lakedrops.com', packages=find_packages(), - py_modules=[], - install_requires=[], + py_modules=['alerta_elastalert'], + install_requires=[ + 'requests' + ], include_package_data=True, zip_safe=True, entry_points={