from .api import start_monitoring, Empty | |
# from influx_exporter import connect, add_data | |
uri = "udp://192.168.0.104:12001" | |
# infldb_url = "influxdb://perf:perf@192.168.152.42:8086/perf" | |
# conn = connect(infldb_url) | |
monitor_config = {'127.0.0.1': | |
{"block-io": {'allowed_prefixes': ['sda1', 'rbd1']}, | |
"net-io": {"allowed_prefixes": ["virbr2"]}}} | |
with start_monitoring(uri, monitor_config) as queue: | |
while True: | |
try: | |
(ip, port), data = queue.get(True, 1) | |
print (ip, port), data | |
# add_data(conn, ip, [data]) | |
except Empty: | |
pass |