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