Pandas相当于Oracle Lead/Lag功能

gca*_*iol 35 python pandas

首先,我是熊猫的新手,但我已经爱上了它.我正在尝试从Oracle实现等效的Lag函数.

我们假设你有这个DataFrame:

Date                   Group      Data
2014-05-14 09:10:00        A         1
2014-05-14 09:20:00        A         2
2014-05-14 09:30:00        A         3
2014-05-14 09:40:00        A         4
2014-05-14 09:50:00        A         5
2014-05-14 10:00:00        B         1
2014-05-14 10:10:00        B         2
2014-05-14 10:20:00        B         3
2014-05-14 10:30:00        B         4
Run Code Online (Sandbox Code Playgroud)

如果这是一个oracle数据库,我想创建一个按"组"列分组并按日期排序的滞后函数,我可以轻松使用此函数:

 LAG(Data,1,NULL) OVER (PARTITION BY Group ORDER BY Date ASC) AS Data_lagged
Run Code Online (Sandbox Code Playgroud)

这将导致下表:

Date                   Group     Data    Data lagged
2014-05-14 09:10:00        A        1           Null
2014-05-14 09:20:00        A        2            1
2014-05-14 09:30:00        A        3            2
2014-05-14 09:40:00        A        4            3
2014-05-14 09:50:00        A        5            4
2014-05-14 10:00:00        B        1           Null
2014-05-14 10:10:00        B        2            1
2014-05-14 10:20:00        B        3            2
2014-05-14 10:30:00        B        4            3
Run Code Online (Sandbox Code Playgroud)

在pandas中我可以将日期设置为索引并使用shift方法:

db["Data_lagged"] = db.Data.shift(1)
Run Code Online (Sandbox Code Playgroud)

唯一的问题是,这不是按列分组.即使我将两列Date和Group设置为索引,我仍然会在滞后列中得到"5".

有没有办法在Pandas中实现等效的Lead和lag函数?

unu*_*tbu 55

您可以执行groupby/apply(shift)操作:

In [15]: df['Data_lagged'] = df.groupby(['Group'])['Data'].shift(1)

In [16]: df
Out[16]: 
                Date Group  Data  Data_lagged
2014-05-14  09:10:00     A     1          NaN
2014-05-14  09:20:00     A     2            1
2014-05-14  09:30:00     A     3            2
2014-05-14  09:40:00     A     4            3
2014-05-14  09:50:00     A     5            4
2014-05-14  10:00:00     B     1          NaN
2014-05-14  10:10:00     B     2            1
2014-05-14  10:20:00     B     3            2
2014-05-14  10:30:00     B     4            3

[9 rows x 4 columns]
Run Code Online (Sandbox Code Playgroud)

要获得ORDER BY Date ASC效果,您必须首先对DataFrame进行排序:

df['Data_lagged'] = (df.sort_values(by=['Date'], ascending=True)
                       .groupby(['Group'])['Data'].shift(1))
Run Code Online (Sandbox Code Playgroud)


nov*_*cem 17

对于 pandas 中的引导操作,只需使用而shift(-1)不是 1

df['Data_lead'] = df.groupby(['Group'])['Data'].shift(-1)