Навыки, которые нужны бизнесу:
SQL для аналитиков данных

Roadmap: 6 недель прикладного SQL под задачи продуктового и бизнес-анализа

Фокусная программа SQL для дата-специалистов: как быстро получать ответы на вопросы менеджмента, рассчитывать финансовые показатели и готовить данные для дашбордов.

WITH event_lags AS (
    SELECT 
        user_id, event_time,
        LAG(event_time) OVER (PARTITION BY user_id ORDER BY event_time) AS prev_time
    FROM user_events
),
session_starts AS (
    SELECT 
        user_id, event_time,
        -- Если пауза > 30 минут, ставим маркер 1 (начало новой сессии)
        CASE WHEN EXTRACT(EPOCH FROM (event_time - prev_time)) / 60 > 30 OR prev_time IS NULL THEN 1 ELSE 0 END AS is_new_session
    FROM event_lags
),
session_ids AS (
    SELECT 
        user_id, event_time,
        -- Нарастающий итог маркеров формирует уникальный ID сессии
        SUM(is_new_session) OVER (PARTITION BY user_id ORDER BY event_time) AS session_id
    FROM session_starts
)
SELECT 
    user_id, session_id,
    MIN(event_time) AS session_start,
    MAX(event_time) AS session_end,
    ROUND(EXTRACT(EPOCH FROM (MAX(event_time) - MIN(event_time))) / 60, 1) AS duration_minutes
FROM session_ids
GROUP BY user_id, session_id;

Это классическая продуктовая задача, требующая комбинации функции LAG и нарастающего итога SUM() OVER() для кластеризации логов в сессии.