0
0
mirror of https://github.com/PostHog/posthog.git synced 2024-11-29 02:46:32 +01:00
posthog/ee/clickhouse/sql/sessions/no_events.py

73 lines
2.3 KiB
Python
Raw Normal View History

SESSIONS_NO_EVENTS_SQL = """
SELECT
distinct_id,
uuid,
event,
properties,
elements_chain,
session_uuid,
session_duration_seconds,
timestamp,
session_end_ts
FROM
(
SELECT
distinct_id,
uuid,
event,
properties,
elements_chain,
if(is_new_session, uuid, NULL) AS session_uuid,
is_new_session,
is_end_session,
if(is_end_session AND is_new_session, 0, if(is_new_session AND (NOT is_end_session), dateDiff('second', toDateTime(timestamp), toDateTime(neighbor(timestamp, 1))), NULL)) AS session_duration_seconds,
timestamp,
if(is_end_session AND is_new_session, timestamp, if(is_new_session AND (NOT is_end_session), neighbor(timestamp, 1), NULL)) AS session_end_ts
FROM
(
SELECT
distinct_id,
uuid,
event,
properties,
elements_chain,
timestamp,
neighbor(distinct_id, -1) AS start_possible_neighbor,
neighbor(timestamp, -1) AS start_possible_prev_ts,
if((start_possible_neighbor != distinct_id) OR (dateDiff('minute', toDateTime(start_possible_prev_ts), toDateTime(timestamp)) > 30), 1, 0) AS is_new_session,
neighbor(distinct_id, 1) AS end_possible_neighbor,
neighbor(timestamp, 1) AS end_possible_prev_ts,
if((end_possible_neighbor != distinct_id) OR (dateDiff('minute', toDateTime(timestamp), toDateTime(end_possible_prev_ts)) > 30), 1, 0) AS is_end_session
FROM
(
SELECT
uuid,
event,
properties,
timestamp,
distinct_id,
elements_chain
FROM events
WHERE
team_id = %(team_id)s
{date_from}
{date_to}
{filters}
GROUP BY
uuid,
event,
properties,
timestamp,
distinct_id,
elements_chain
ORDER BY
distinct_id ASC,
timestamp ASC
)
)
WHERE (is_new_session AND (NOT is_end_session)) OR (is_end_session AND (NOT is_new_session)) OR (is_end_session AND is_new_session)
)
WHERE is_new_session
{sessions_limit}
"""