birbnetes/birb_latency_collector
birbnetes/birb_latency_collector
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

anyád
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Pünkösd Marcell 2021-12-09 22:20:13 +01:00
parent 97beca5539
commit 7809e968f4
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
birb_latency_collector/views/report_view.py
View File

@ -40,7 +40,7 @@ class ReportView(FlaskView):
|> timedMovingAverage(every: 30s, period: 1m) |> timedMovingAverage(every: 30s, period: 1m)
|> last() |> last()
|> yield()""" |> yield()"""
latency_tables = influxdb_instance.query_api(query) latency_tables = influxdb_instance.query_api.query(query)
for table in latency_tables: for table in latency_tables:
for value in table.values: for value in table.values:
@ -58,7 +58,7 @@ class ReportView(FlaskView):
|> timedMovingAverage(every: 30s, period: 1m) |> timedMovingAverage(every: 30s, period: 1m)
|> last() |> last()
|> yield()""" |> yield()"""
rate_tables = influxdb_instance.query_api(query) rate_tables = influxdb_instance.query_api.query(query)
for table in rate_tables: for table in rate_tables:
for value in table.values: for value in table.values:
@ -102,7 +102,7 @@ class ReportView(FlaskView):
|> timedMovingAverage(every: 30s, period: 1m) |> timedMovingAverage(every: 30s, period: 1m)
|> last() |> last()
|> yield()""" |> yield()"""
queue_tables = influxdb_instance.query_api(query) queue_tables = influxdb_instance.query_api.query(query)
for table in queue_tables: for table in queue_tables:
for value in table.values: for value in table.values:
@ -136,7 +136,6 @@ class ReportView(FlaskView):
@route("/site", methods=['GET']) @route("/site", methods=['GET'])
def site_get(self): def site_get(self):
q = influxdb_instance.connection.query_api()
response = {} response = {}
# Query queue # Query queue
@ -147,7 +146,7 @@ class ReportView(FlaskView):
|> timedMovingAverage(every: 30s, period: 1m) |> timedMovingAverage(every: 30s, period: 1m)
|> last() |> last()
|> yield()""" |> yield()"""
queue_tables = influxdb_instance.query_api(query) queue_tables = influxdb_instance.query_api.query(query)
for table in queue_tables: for table in queue_tables:
for value in table.values: for value in table.values: