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

Fine tuned measurement recording
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-02 23:08:25 +01:00
parent 3ea9174692
commit ef69940f2f
1 changed files with 45 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
birb_latency_collector/views/report_view.py
View File

@ -1,26 +1,63 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
from flask import jsonify, request, abort, current_app, Response from flask import request, current_app, Response
from flask_classful import FlaskView from flask_classful import FlaskView, route
from utils import json_required, influxdb_instance from utils import json_required, influxdb_instance
from influxdb_client import Point from influxdb_client import Point
class ReportView(FlaskView): class ReportView(FlaskView):
@route("/link", methods=['POST'])
@json_required @json_required
def post(self): def link(self):
data = request.json data = request.json
points = [] points = []
for type_ in ['latency', 'queue', 'rate']: for type_ in ['latency', 'rate']:
if type_ in data['measurements']: if type_ in data['measurements']:
points.append( points.append(
Point(type_) Point(f"link_{type_}")
.tag("client", data['client']) .tag("client", data['client'])
.tag("cloud", data['cloud']) .tag("site", data['site'])
.field("latency", data['measurements'][type_]) .field("value", data['measurements'][type_])
) )
influxdb_instance.connection.write_api().write("alma", "alma", points) influxdb_instance.connection.write_api().write("alma", current_app.config['INFLUXDB_V2_ORG'], points)
return Response(status=201)
@route("/client", methods=['POST'])
@json_required
def client(self):
data = request.json
points = []
for type_ in ['queue']:
if type_ in data['measurements']:
points.append(
Point(f"client_{type_}")
.tag("client", data['client'])
.field("value", data['measurements'][type_])
)
influxdb_instance.connection.write_api().write("alma", current_app.config['INFLUXDB_V2_ORG'], points)
return Response(status=201)
@route("/site", methods=['POST'])
@json_required
def site(self):
data = request.json
points = []
for type_ in ['queue']:
if type_ in data['measurements']:
points.append(
Point(f"site_{type_}")
.tag("site", data['site'])
.field("value", data['measurements'][type_])
)
influxdb_instance.connection.write_api().write("alma", current_app.config['INFLUXDB_V2_ORG'], points)
return Response(status=201) return Response(status=201)