| 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 |