mirror of https://github.com/alerta/alerta.git
33 lines
919 B
Python
33 lines
919 B
Python
from typing import Any, Dict
|
|
|
|
from flask import current_app
|
|
|
|
from alerta.models.alert import Alert
|
|
|
|
from . import WebhookBase
|
|
|
|
JSON = Dict[str, Any]
|
|
|
|
|
|
class RiemannWebhook(WebhookBase):
|
|
"""
|
|
Riemann HTTP client
|
|
http://riemann.io/clients.html
|
|
"""
|
|
|
|
def incoming(self, path, query_string, payload):
|
|
|
|
return Alert(
|
|
resource=f"{payload['host']}-{payload['service']}",
|
|
event=payload.get('event', payload['service']),
|
|
environment=payload.get('environment', current_app.config['DEFAULT_ENVIRONMENT']),
|
|
severity=payload.get('state', 'unknown'),
|
|
service=[payload['service']],
|
|
group=payload.get('group', 'Performance'),
|
|
text=payload.get('description', None),
|
|
value=payload.get('metric', None),
|
|
tags=payload.get('tags', None),
|
|
origin='Riemann',
|
|
raw_data=payload
|
|
)
|