graphana integration
diff --git a/sensors/receiver.py b/sensors/receiver.py
index 369a65f..8903f24 100644
--- a/sensors/receiver.py
+++ b/sensors/receiver.py
@@ -9,35 +9,33 @@
infldb_url = "influxdb://perf:perf@192.168.152.42:8086/perf"
conn = connect(infldb_url)
-sw_per_ip = {}
-count = 4
-expected = ['192.168.0.104', '192.168.152.41',
- '192.168.152.39', '192.168.152.40']
+# sw_per_ip = {}
+# count = 4
+# expected = sorted(monitor_config.keys())
+
+# if 'sda1.sectors_written' in data:
+# val = data['sda1.sectors_written']
+# elif 'sdb.sectors_written' in data:
+# val = data['sdb.sectors_written']
+# else:
+# val = 0
+
+# sw_per_ip[ip] = sw_per_ip.get(ip, 0) + val
+# count -= 1
+
+# if 0 == count:
+# try:
+# vals = [sw_per_ip[ip] for ip in expected]
+# print ("{:>6}" * len(expected)).format(*vals)
+# sw_per_ip = {}
+# count = 4
+# except KeyError:
+# pass
with start_monitoring(uri, monitor_config) as queue:
while True:
try:
(ip, port), data = queue.get(True, 1)
-
- if 'sda1.sectors_written' in data:
- val = data['sda1.sectors_written']
- elif 'sdb.sectors_written' in data:
- val = data['sdb.sectors_written']
- else:
- val = 0
-
- sw_per_ip[ip] = sw_per_ip.get(ip, 0) + val
- count -= 1
-
- if 0 == count:
- try:
- vals = [sw_per_ip[ip] for ip in expected]
- print ("{:>6}" * 4).format(*vals)
- sw_per_ip = {}
- count = 4
- except KeyError:
- pass
-
add_data(conn, ip, [data])
except Empty:
pass