From ac0c8f999eebea4009f82010954aa5f6074679ba Mon Sep 17 00:00:00 2001 From: marcsello Date: Thu, 9 Dec 2021 23:38:04 +0100 Subject: [PATCH] =?UTF-8?q?any=C3=A1dba=20m=C3=A1r?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- birb_latency_collector/views/report_view.py | 32 ++++++++++----------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/birb_latency_collector/views/report_view.py b/birb_latency_collector/views/report_view.py index 1f73d26..3c89e3d 100644 --- a/birb_latency_collector/views/report_view.py +++ b/birb_latency_collector/views/report_view.py @@ -43,12 +43,12 @@ class ReportView(FlaskView): latency_tables = influxdb_instance.query_api.query(query) for table in latency_tables: - for value in table.values: - key = value['client'] + ":" + value['site'] + for row in table.records: + key = row.values['client'] + ":" + row.values['site'] if key in response: - response[key]['latency'] = value['_value'] + response[key]['latency'] = row.values['_value'] else: - response[key] = {'latency': value['_value']} + response[key] = {'latency': row.values['_value']} # Query rate @@ -61,12 +61,12 @@ class ReportView(FlaskView): rate_tables = influxdb_instance.query_api.query(query) for table in rate_tables: - for value in table.values: - key = value['client'] + ":" + value['site'] + for row in table.records + key = row.values['client'] + ":" + row.values['site'] if key in response: - response[key]['rate'] = value['_value'] + response[key]['rate'] = row.values['_value'] else: - response[key] = {'rate': value['_value']} + response[key] = {'rate': row.values['_value']} return jsonify(response) @@ -105,12 +105,12 @@ class ReportView(FlaskView): queue_tables = influxdb_instance.query_api.query(query) for table in queue_tables: - for value in table.values: - key = value['client'] + for row in table.records: + key = row.values['client'] if key in response: - response[key]['queue'] = value['_value'] + response[key]['queue'] = row.values['_value'] else: - response[key] = {'queue': value['_value']} + response[key] = {'queue': row.values['_value']} return jsonify(response) @@ -149,11 +149,11 @@ class ReportView(FlaskView): queue_tables = influxdb_instance.query_api.query(query) for table in queue_tables: - for value in table.values: - key = value['site'] + for row in table.records: + key = row.values['site'] if key in response: - response[key]['queue'] = value['_value'] + response[key]['queue'] = row.values['_value'] else: - response[key] = {'queue': value['_value']} + response[key] = {'queue': row.values['_value']} return jsonify(response)