mirror of
https://github.com/alerta/alerta-contrib.git
synced 2025-03-17 05:52:38 +00:00
102 lines
No EOL
3.6 KiB
Python
102 lines
No EOL
3.6 KiB
Python
|
|
import re
|
|
import logging
|
|
import fnmatch
|
|
|
|
LOG = logging.getLogger("alerta.transform")
|
|
|
|
try:
|
|
import settings
|
|
except ImportError:
|
|
settings = {'parsers': []}
|
|
|
|
|
|
class Transformers(object):
|
|
|
|
@staticmethod
|
|
def normalise_alert(alert, trapoid=None, facility=None, level=None, **kwargs):
|
|
"""
|
|
Transforms alert based on configuration contained in settings file.
|
|
"""
|
|
suppress = False
|
|
|
|
for c in settings.PARSERS:
|
|
LOG.debug('Parser:', c)
|
|
|
|
match = None
|
|
pattern = None
|
|
|
|
if alert.event_type == 'snmptrapAlert' and trapoid and c.get('trapoid'):
|
|
match = re.match(c['trapoid'], trapoid)
|
|
pattern = trapoid
|
|
elif alert.event_type == 'syslogAlert' and facility and level and c.get('priority'):
|
|
match = fnmatch.fnmatch('%s.%s' % (facility, level), c['priority'])
|
|
pattern = c['priority']
|
|
elif c.get('match'):
|
|
try:
|
|
match = all(item in alert.__dict__.items() for item in c['match'].items())
|
|
pattern = c['match'].items()
|
|
except AttributeError:
|
|
pass
|
|
|
|
if match:
|
|
LOG.debug('Matched %s for %s', pattern, alert.event_type)
|
|
|
|
# 1. Simple substitutions
|
|
if 'resource' in c:
|
|
alert.resource = c['resource']
|
|
if 'event' in c:
|
|
alert.event = c['event']
|
|
if 'environment' in c:
|
|
alert.environment = c['environment']
|
|
if 'severity' in c:
|
|
alert.severity = c['severity']
|
|
if 'correlate' in c:
|
|
alert.correlate = c['correlate']
|
|
if 'status' in c:
|
|
alert.correlate = c['status']
|
|
if 'service' in c:
|
|
alert.service = c['service']
|
|
if 'group' in c:
|
|
alert.group = c['group']
|
|
if 'value' in c:
|
|
alert.value = c['value']
|
|
if 'text' in c:
|
|
alert.text = c['text']
|
|
if 'tags' in c:
|
|
alert.tags.append(c['tags']) # join tags
|
|
if 'attributes' in c:
|
|
alert.attributes.update(c['attributes']) # merge attributes
|
|
if 'origin' in c:
|
|
alert.timeout = c['origin']
|
|
if 'event_type' in c:
|
|
alert.timeout = c['event_type']
|
|
if 'timeout' in c:
|
|
alert.timeout = c['timeout']
|
|
|
|
# 2. Complex transformations
|
|
if 'parser' in c:
|
|
LOG.debug('Loading parser %s', c['parser'])
|
|
|
|
context = kwargs
|
|
context.update(alert.__dict__)
|
|
|
|
try:
|
|
exec(open('%s/%s.py' % (settings.PARSER_DIR, c['parser']))) in globals(), context
|
|
LOG.info('Parser %s/%s exec OK', settings.PARSER_DIR, c['parser'])
|
|
except Exception, e:
|
|
LOG.warning('Parser %s failed: %s', c['parser'], e)
|
|
raise RuntimeWarning
|
|
|
|
for k, v in context.iteritems():
|
|
if hasattr(alert, k):
|
|
setattr(alert, k, v)
|
|
|
|
if 'suppress' in context:
|
|
suppress = context['suppress']
|
|
|
|
# 3. Suppress based on results of 1 or 2
|
|
if 'suppress' in c:
|
|
suppress = suppress or c['suppress']
|
|
|
|
return suppress |