mirror of
https://github.com/alerta/alerta.git
synced 2025-02-06 06:20:03 +00:00
30 lines
683 B
Python
30 lines
683 B
Python
|
|
import socket
|
|
|
|
from alerta.app import app
|
|
from alerta.plugins import PluginBase
|
|
|
|
LOG = app.logger
|
|
|
|
|
|
class LogStashOutput(PluginBase):
|
|
|
|
def pre_receive(self, alert):
|
|
|
|
pass
|
|
|
|
def post_receive(self, alert):
|
|
|
|
try:
|
|
self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
self.sock.connect((app.config['LOGSTASH_HOST'], app.config['LOGSTASH_PORT']))
|
|
except Exception:
|
|
raise RuntimeError("Logstash connection error")
|
|
|
|
try:
|
|
self.sock.send("%s\r\n" % alert)
|
|
except Exception as e:
|
|
LOG.exception(e)
|
|
raise RuntimeError("logstash exception")
|
|
|
|
self.sock.close()
|