1 回答

TA貢獻1828條經驗 獲得超3個贊
我是這樣做的:
添加行標記每個組的開頭,給它們值ffill:
extra_times = pandas.date_range(t_0, periods=3, freq='1H')
pdf_reindexed = (pandas
.concat([pdf_query, pandas.DataFrame(index=extra_times)], sort=False)
.sort_index()
.ffill()
)
添加差異列span:
timestamp = pdf_reindexed.index.to_series()
pdf_reindexed["span"] = (timestamp.shift(-1) - timestamp).dt.seconds
乘以:value_span
pdf_reindexed["product"] = pdf_reindexed["span"] * pdf_reindexed["Sensor1"]
聚合和分割:
pdf_time_mean = (pdf_reindexed
.resample("1H")
.agg({"product": "sum"})
)
pdf_time_mean["product"] = pdf_time_mean["product"] / 3600
添加回答
舉報