Merge pull request #184 from netantho/averez-observium

averez-observium: Observium plugin by @XioNoX

mq/plugins/observium.py

@@ -0,0 +1,36 @@
+# This Source Code Form is subject to the terms of the Mozilla Public
+# License, v. 2.0. If a copy of the MPL was not distributed with this
+# file, You can obtain one at http://mozilla.org/MPL/2.0/.
+# Copyright (c) 2014 Mozilla Corporation
+#
+# Contributors:
+# Arzhel Younsi arzhel@mozilla.com
+
+import re
+
+class message(object):
+    def __init__(self):
+        '''register our criteria for being passed a message
+           as a list of lower case strings or values to match with an event's dictionary of keys or values
+           set the priority if you have a preference for order of plugins to run.
+           0 goes first, 100 is assumed/default if not sent
+        '''
+        self.registration = ['observium']
+        self.priority = 5
+        self.regex = re.compile(r'(?P<alert_type>\S+): \[(?P<source_host>\S+)\] \[(?P<entity_type>\S+)\] \[(?P<entity>.*)\] (?P<alert_message>.*)')
+
+    def onMessage(self, message, metadata):
+        if 'details' in message.keys():
+            if 'program' in message['details'].keys():
+                if 'Observium' == message['details']['program']:
+                    msg_unparsed = message['summary']
+                    search = re.search(self.regex, msg_unparsed)
+                    if search:
+                        message['details']['alert_type'] = search.group('alert_type')
+                        message['details']['entity_type'] = search.group('entity_type')
+                        message['details']['sourcehostname'] = search.group('source_host')
+                        message['details']['entity'] = search.group('entity')
+                        message['details']['alert_message'] = search.group('alert_message')
+
+        return (message, metadata)
+