Postgresql 中的时间窗口滚动总和

Question

我想知道是否可以在 Postgresql 中使用基于时间的窗口查询。

\n

原始数据位于前三列（日期、销售员、金额）：

\n

\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n \n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n \n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n

日期	推销员	数量	3 滚动天数总和
2020-01-01	约翰	10	10
2020-01-02	约翰	15	25
2020-01-03	约翰	8	33
2020-01-04	约翰	12	35
2020-01-05	约翰	11	31
2020-01-01	丹尼尔	5	5
2020-01-02	丹尼尔	6	11
2020-01-03	丹尼尔	7	18
2020-01-04	丹尼尔	8	21
2020-01-05	丹尼尔	9	24

\n

\n

第四列表示该销售员在过去三个滚动日内的总金额。

\n

Pandas 有内置函数可以做到这一点，但我想不出任何方法可以使用内置sum() over ()语法在 Postgresql 中做到这一点。我能够做到的唯一方法是使用横向连接和子查询的复杂组合以及时间增量比较的条件，至少可以说这是不优雅的。

\n

Pandas\' 方式（根据记忆，确切的语法可能略有不同） \xe2\x80\x94 无法获得任何简洁的信息：

\n

df.groupby(\'salesman\').rolling(\'3d\').sum()\n

\n

Answer 1

演示：db<>fiddle

SELECT
    *,
    SUM(amount) OVER (
        PARTITION BY salesman                     -- 1
        ORDER BY "date"                           -- 2
        ROWS BETWEEN 2 PRECEDING AND CURRENT ROW  -- 3
    )
FROM mytable

1. 通过 . 构建组/分区salesman。因此，以下操作仅在这些分区内完成
2. date按列排序
3. 仅对当前日期之前 2 个日期与当前日期之间的记录进行求和。这是滚动部分

如果您使用的是 Postgres 11RANGE或更高版本，您可以使用日期间隔而不是计数来更精确地定义窗口ROWS：

SELECT
    *,
    SUM(amount) OVER (
        PARTITION BY salesman                    
        ORDER BY "date"                          
        RANGE BETWEEN interval '2 days' PRECEDING AND CURRENT ROW
    )
FROM mytable