本文详解如何在 Pandas 中对多代码（code）并行的时间序列数据，按 code 分组、以时间顺序前向填充（ffill）标记为 -1 的无效值，并确保每个时间点输出都携带该 code 下截至该时刻的最新有效值。
本文详解如何在 pandas 中对多代码（code）并行的时间序列数据，按 `code` 分组、以时间顺序前向填充（ffill）标记为 `-1` 的无效值，并确保每个时间点输出都携带该 code 下截至该时刻的最新有效值。
在金融、IoT 或日志类时序分析场景中，常遇到带标识码（如 code）的多实体时间序列数据，其中部分字段使用特殊值（如 -1）表示缺失或无效。此时若需按时间线逐点输出「每个实体在该时刻的最新有效观测」，关键在于：前向填充必须在每个 code 内部独立进行，且严格遵循时间先后顺序——而非按时间戳全局分组（如原方案中 groupby('calendardate')），否则将破坏时序依赖关系，导致跨实体污染或丢失历史状态。
正确的实现逻辑分为三步：
- 将标记值 -1 统一替换为 NaN（Pandas 原生识别的缺失值符号，确保 ffill 行为准确）；
- 按 code 分组后，对目标列（A, B, C）执行 ffill() —— 此操作自动基于每组内 calendardate 的自然排序（若未显式排序，ffill 仍按原始行序，故需提前确保数据已按时间升序排列）；
- 最终按 calendardate 全局排序，便于后续按时间切片遍历或可视化。
以下是完整可运行示例（兼容 Pandas 2.2+）：
import pandas as pd
import numpy as np
# 构建示例数据
data = {
'code': ['A1', 'A1', 'A1', 'A1', 'A1', 'A1', 'B1', 'B1', 'B1', 'B1'],
'calendardate': [
'2024-02-29 09:00:00', '2024-02-29 09:05:00', '2024-02-29 09:10:00', '2024-02-29 09:15:00',
'2024-02-29 09:20:00', '2024-02-29 09:25:00', '2024-02-29 09:00:00', '2024-02-29 09:05:00',
'2024-02-29 09:10:00', '2024-02-29 09:15:00'
],
'A': [10, -1, 20, -1, 30, 40, 50, -1, -1, 60],
'B': [-1, 15, -1, 25, -1, 35, -1, 45, -1, -1],
'C': [-1, -1, -1, 35, -1, -1, -1, -1, 55, 65]
}
df = pd.DataFrame(data)
df['calendardate'] = pd.to_datetime(df['calendardate'])
# ✅ 关键步骤：先按 code 分组，再对 A/B/C 列 ffill（自动基于组内行序）
# 注意：务必确保每组内 calendardate 已升序排列（此处原始数据已满足，否则加 sort_values）
cols = ['A', 'B', 'C']
df[cols] = df.replace(-1, np.nan).groupby('code')[cols].ffill()
# 按时间全局排序，便于按时间线迭代
df = df.sort_values('calendardate').reset_index(drop=True)
# 验证结果（按时间点逐行输出）
for _, row in df.iterrows():
print(f"Datetime: {row['calendardate']}")
print(f"Code: {row['code']}")
print(f"A: {row['A'] if pd.notna(row['A']) else 'N/A'}")
print(f"B: {row['B'] if pd.notna(row['B']) else 'N/A'}")
print(f"C: {row['C'] if pd.notna(row['C']) else 'N/A'}")
print("-" * 30)
输出关键片段验证（与预期一致）：
Datetime: 2024-02-29 09:05:00 Code: A1 A: 10.0 B: 15.0 C: N/A ------------------------------
⚠️ 重要注意事项：
- 排序是前提：groupby().ffill() 默认按组内原始行序填充。若原始数据中同一 code 的 calendardate 无序，必须先执行 df.sort_values(['code', 'calendardate'])，否则填充结果将错误。
- 避免 groupby('calendardate')：原方案错误地按时间戳分组，导致不同 code 的数据被混入同一组，丧失独立性。
- replace(-1, np.nan) 不可省略：直接对 -1 调用 ffill() 无效，因 -1 是有效数值；必须转为 NaN 才触发缺失值填充逻辑。
- 性能优化：对于超大数据集，可考虑 groupby(..., observed=True) 或使用 pd.api.types.CategoricalDtype 加速分组。
此方法简洁、高效、符合 Pandas 向量化设计哲学，是处理多实体时序标记值填充的标准范式。
