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

change(api): ch query updates - heatmaps fix

Browse source
This commit is contained in:
Shekar Siri 2025-01-20 18:05:42 +01:00
parent 60b795ffbf
commit ca142f17de
1 changed files with 16 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
api/chalicelib/core/metrics/heatmaps_ch.py
View file

@ -365,19 +365,21 @@ def get_selected_session(project_id, session_id):
def get_page_events(session_id, project_id):
with ch_client.ClickHouseClient() as cur:
rows = cur.execute("""\
SELECT
event_id,
toUnixTimestamp(created_at)*1000 AS timestamp,
JSON_VALUE(CAST($properties AS String), '$.url_host') AS host,
JSON_VALUE(CAST($properties AS String), '$.url_path') AS path,
JSON_VALUE(CAST($properties AS String), '$.url_path') AS value,
JSON_VALUE(CAST($properties AS String), '$.url_path') AS url,
'LOCATION' AS type
FROM product_analytics.events
WHERE session_id = %(session_id)s
AND `$event_name`='LOCATION'
AND project_id= %(project_id)s
ORDER BY datetime,message_id;""", {"session_id": session_id, "project_id": project_id})
query = cur.format(query=f"""SELECT
event_id as message_id,
toUnixTimestamp(created_at)*1000 AS timestamp,
JSON_VALUE(CAST(`$properties` AS String), '$.url_host') AS host,
JSON_VALUE(CAST(`$properties` AS String), '$.url_path') AS path,
JSON_VALUE(CAST(`$properties` AS String), '$.url_path') AS value,
JSON_VALUE(CAST(`$properties` AS String), '$.url_path') AS url,
'LOCATION' AS type
FROM product_analytics.events
WHERE session_id = %(session_id)s
AND `$event_name`='LOCATION'
AND project_id= %(project_id)s
ORDER BY created_at,message_id;""",
parameters={"session_id": session_id, "project_id": project_id})
rows = cur.execute(query=query)
rows = helper.list_to_camel_case(rows)
return rows