6 Mar
2017
6 Mar
'17
6:20 a.m.
Module: check_mk
Branch: master
Commit: d0b1a5fce9a4786959eb873c722cd3997718c127
URL:
http://git.mathias-kettner.de/git/?p=check_mk.git;a=commit;h=d0b1a5fce9a478…
Author: Sven Panne <sp(a)mathias-kettner.de>
Date: Mon Mar 6 12:13:55 2017 +0100
Added a clean example for talking to the mkeventd.
Change-Id: I0f5b9ab535193a298f7d1da3945dfa4be10e4acf
---
doc/treasures/read_from_mkeventd.py | 83 +++++++++++++++++++++++++++++++++++++
1 file changed, 83 insertions(+)
diff --git a/doc/treasures/read_from_mkeventd.py b/doc/treasures/read_from_mkeventd.py
new file mode 100755
index 0000000..95a9e18
--- /dev/null
+++ b/doc/treasures/read_from_mkeventd.py
@@ -0,0 +1,83 @@
+#!/usr/bin/python
+# "How to talk to the mkeventd", Python edition :-)
+
+import json
+import os
+import socket
+
+class EventConsoleConnection:
+ def __init__(self, path, timeout=3):
+ self._socket = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
+ self._socket.settimeout(timeout)
+ self._socket.connect(path)
+ self._buffer = ""
+
+ def send_request(self, request):
+ self._socket.sendall(request);
+ self._socket.shutdown(socket.SHUT_WR)
+
+ def read_response(self):
+ """Return the whole response as a byte string"""
+ buffer = ""
+ while True:
+ data = self._socket.recv(4096)
+ if len(data) == 0:
+ return buffer
+ buffer += data
+
+ def lines(self):
+ return ResponseLines(self._socket)
+
+ def close(self):
+ self._socket.close()
+
+ def __iter__(self):
+ """Return an iterator for reading the response as Unicode
lines"""
+ return self
+
+ def next(self):
+ while True:
+ parts = self._buffer.split("\n", 1)
+ if len(parts) > 1:
+ break
+ data = self._socket.recv(4096)
+ if len(data) == 0:
+ if len(self._buffer) == 0:
+ raise StopIteration()
+ parts = [self._buffer, ""]
+ break
+ self._buffer += data
+ line, self._buffer = parts
+ return line.decode("utf-8").splitlines()
+
+ def __enter__(self):
+ return self
+
+ def __exit__(self, ty, value, traceback):
+ self.close()
+
+def request(what, path):
+ """Submit a request to the event console, returning the reply as a
python object"""
+ with EventConsoleConnection(path) as c:
+ c.send_request(what + "\nOutputFormat: json")
+ return json.loads(c.read_response())
+
+################################################################################
+
+path = os.getenv("OMD_ROOT") + "/tmp/run/mkeventd/status"
+
+# read the response line by line
+with EventConsoleConnection(path) as c:
+ c.send_request("GET status\nOutputFormat: plain")
+ for line in c:
+ print line
+
+# read the whole response in one go
+with EventConsoleConnection(path) as c:
+ c.send_request("GET status\nOutputFormat: python")
+ print(c.read_response())
+
+# use the convenience function
+print(request("GET status", path))
+print(request("COMMAND SYNC", path))
+print(request("REPLICATE 1488791495", path))