Timedelta滚动列表window_mask遗漏首条记录的问题排查与修复

问题根源 #

计数偏差（Value=5计数为7，期望8）的核心原因是滚动窗口的时间差判断错误使用了绝对值。

滚动统计的正确逻辑是仅保留当前处理行时间往前推5分钟范围内的记录，即记录时间需满足 当前时间 - 记录时间 ≤ 5分钟（或等价的 记录时间 ≥ 当前时间 - 5分钟）。但你用了绝对值判断，当首条记录与当前行的时间差为5分05秒时，abs(当前时间 - 记录时间) 结果仍为5分05秒，超过5分钟阈值，导致这条本应被包含的记录被错误排除。

修复方案 #

错误代码示例（原逻辑） #

# 错误：使用绝对值判断时间差
window_mask = abs(current_time - self.cur['time']) <= pd.Timedelta('5min')
filtered_records = self.cur[window_mask]

修复后的代码 #

推荐用更直观的窗口范围判断，避免时间差正负的混淆：

# 计算窗口起始时间：当前时间往前推5分钟
window_start = current_time - pd.Timedelta('5min')
# 仅保留时间在窗口起始时间之后的记录
window_mask = self.cur['time'] >= window_start
filtered_records = self.cur[window_mask]

如果坚持用时间差判断，去掉绝对值即可（前提是数据按时间顺序处理，记录时间不会晚于当前处理行时间）：

window_mask = (current_time - self.cur['time']) <= pd.Timedelta('5min')
filtered_records = self.cur[window_mask]

验证效果 #

修复后，首条记录若时间落在当前时间-5分钟范围内，会被正确保留，Value=5的计数会符合预期的8。

内容的提问来源于stack exchange，提问作者Daniel