From 96aa2b020f531cb1c5276ff43ef56547f2588090 Mon Sep 17 00:00:00 2001 From: Sven Slootweg Date: Sun, 8 Dec 2013 19:32:01 +0100 Subject: [PATCH] Add collectd listening script --- ccollectd/listen | 12 ++++++++++++ 1 file changed, 12 insertions(+) create mode 100644 ccollectd/listen diff --git a/ccollectd/listen b/ccollectd/listen new file mode 100644 index 0000000..9de1bf1 --- /dev/null +++ b/ccollectd/listen @@ -0,0 +1,12 @@ +import socket, yaml, random, zmq, msgpack, time, uuid, fnmatch +import cPickle as pickle + +ctx = zmq.Context() + +fetcher = ctx.socket(zmq.SUB) +fetcher.setsockopt(zmq.SUBSCRIBE, "") +fetcher.connect("ipc:///tmp/ccollectd-stats") + +while True: + message = msgpack.unpackb(fetcher.recv()) + print message