jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(alerts): optimized generated query

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-08-26 16:26:16 +01:00
parent 89278b16d0
commit 8e4f48678f
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
api/chalicelib/core/alerts_processor.py
View file

@ -94,7 +94,7 @@ def can_check(a) -> bool:
def Build(a): def Build(a):
params = {"project_id": a["projectId"]} params = {"project_id": a["projectId"], "now": TimeUTC.now()}
full_args = {} full_args = {}
j_s = True j_s = True
if a["seriesId"] is not None: if a["seriesId"] is not None:
@ -121,8 +121,8 @@ def Build(a):
if a["seriesId"] is not None: if a["seriesId"] is not None:
q += f""" FROM ({subQ}) AS stat""" q += f""" FROM ({subQ}) AS stat"""
else: else:
q += f""" FROM ({subQ} AND timestamp>=%(startDate)s q += f""" FROM ({subQ} AND timestamp>=%(startDate)s AND timestamp<=%(now)s
{"AND sessions.start_ts >= %(startDate)s" if j_s else ""}) AS stat""" {"AND sessions.start_ts >= %(startDate)s AND sessions.start_ts <= %(now)s" if j_s else ""}) AS stat"""
params = {**params, **full_args, "startDate": TimeUTC.now() - a["options"]["currentPeriod"] * 60 * 1000} params = {**params, **full_args, "startDate": TimeUTC.now() - a["options"]["currentPeriod"] * 60 * 1000}
else: else:
if a["options"]["change"] == schemas.AlertDetectionChangeType.change: if a["options"]["change"] == schemas.AlertDetectionChangeType.change: