擅长:python、mysql、java
<p>如果时间间隔的大小相同,可以执行以下操作:</p>
<pre><code>import pandas as pd
from pandas.stats.moments import rolling_sum
def processGroup(df):
df = df.sort('DATE')
df['VIEWS_CUM_BEFORE'] = rolling_sum(df['VIEWS'], window = 7 * 7, min_periods = 1)
return df
df = df.groupby('GROUP').transform(processGroup)
</code></pre>