Я воспроизвел входные данные с помощью этого кода
df = pd.DataFrame({'DATE_LOCATION': ['07-08-16 0:00', '08-08-16 0:00', '12-08-16 0:00',\
'13-08-16 0:00', '14-08-16 0:00', '15-08-16 0:00',\
'22-10-16 0:00', '23-10-16 0:00', '26-10-16 0:00',\
'28-10-16 0:00', '29-10-16 0:00', '30-10-16 0:00',],\
'Sold': [2, 7, 3, 1, 2, 1, 1, 2, 1, 1, 3, 3]})
df.DATE_LOCATION = pd.to_datetime(df.DATE_LOCATION, dayfirst=True)
Теперь данные выглядят так:
DATE_LOCATION Sold
0 2016-08-07 2
1 2016-08-08 7
2 2016-08-12 3
3 2016-08-13 1
4 2016-08-14 2
5 2016-08-15 1
6 2016-10-22 1
7 2016-10-23 2
8 2016-10-26 1
9 2016-10-28 1
10 2016-10-29 3
11 2016-10-30 3
Получите интервал между строками, вычислите длину прогона (последовательные дни) и сгруппируйте их какПоскольку длина пробега продолжает увеличиваться, в конечном итоге получите максимальную длину пробега и сумму проданных предметов в каждой группе.
df['Day_Interval'] = df.DATE_LOCATION.diff().shift(0).fillna(0)
# calculate run length
day_intervals = (df.Day_Interval.values / np.timedelta64(1, 'D')).astype(int)
run_lengths = []
run_length = 0
groups = []
group = 0
for day_interval in day_intervals:
if day_interval != 1:
run_length = 1
group += 1
groups.append(group)
else:
run_length += 1
groups.append(group)
run_lengths.append(run_length)
df['Run_Length'] = run_lengths
df['Group'] = groups
# calculate summary statistic by group
df = df.groupby('Group')['Sold', 'Run_Length'].agg({'Sold': np.sum, 'Run_Length': np.max})
df['1-3'] = 0
df['4-7'] = 0
df['8-15'] = 0
df['>=16'] = 0
df.loc[(df.Run_Length >= 1) & (df.Run_Length <=3), "1-3"] = df.Sold
df.loc[(df.Run_Length >= 4) & (df.Run_Length <=7), "4-7"] = df.Sold
df.loc[(df.Run_Length >= 8) & (df.Run_Length <=15), "8-15"] = df.Sold
df.loc[(df.Run_Length >= 16), ">=16"] = df.Sold
df = df.T.iloc[2:]
df['Sold'] = df.sum(axis=1)
df = df[['Sold']]
Вывод (df
):
Group Sold
1-3 20
4-7 7
8-15 0
>=16 0
Надеюсь, этопомогает.