Блог

У меня в таблице есть данные временных рядов, которые выглядят следующим образом:

  id | company | created_at
  1 | a       | 2021-31-07 11:15:24
  2 | b       | 2021-20-06 10:15:24
  3 | c       | 2021-10-05 08:15:24
 

Я вычисляю разницу во времени (дельту) между каждой строкой. Но я хочу сделать это в другие сроки. Например, 7 дней, 30 дней и 60 дней.

Это мой SQL для вычисления дельты:

 WITH previous_dates AS (
    SELECT
        *,
        LAG(created_at, 1) OVER (PARTITION BY company ORDER BY id DESC) previous_created_at
    FROM time_series_table
),
calculated_datediffs AS (
    SELECT
        *,
        EXTRACT(EPOCH FROM previous_created_at::TIMESTAMP) - EXTRACT(EPOCH FROM created_at::TIMESTAMP) datediff_in_seconds
    FROM previous_dates
)

select * from calculated_datediffs
 

Я пытался использовать FILTER(WHERE date BETWEEN CURRENT_DATE - 7 AND CURRENT_DATE - 1) с LAG , но это дает мне ошибку. В нем говорится::
FILTER is not implemented for non-aggregate window functions

Я хочу улучшить этот запрос, чтобы рассчитать дельту для записей 7-дневной, 30-дневной и 60-дневной давности.

Конечный результат должен выглядеть так:

  id | company | created_at          | 30_days_diff | 7_days_diff (made up numbers)
  1 | a       | 2021-31-07 11:15:24 | 6247.123     | 30123.123
  2 | b       | 2021-20-06 10:15:24 | 741724.123   | 1274.123
  3 | c       | 2021-10-05 08:15:24 | 127715.123   | 885.123
 

Как это сделать?