当前位置：首页 > 文章列表 > 文章 > python教程 > Pandas 分组时间列计算滚动均值方法

Pandas 分组时间列计算滚动均值方法

2026-04-02 11:36:25 0浏览收藏

本文深入解析了在 Pandas 中对分组时序数据（如按股票代码 ISIN 分组）基于时间列（如 date_x）高效、准确计算滚动均值的关键技巧，直击开发者常遇的 `ValueError: invalid on specified as date_x` 根本原因——错误地在 Series 上使用仅 DataFrame 支持的 `on=` 参数，并提供两种生产级可靠方案：一是通过 `groupby().apply()` 结合子 DataFrame 的 `rolling(on=...)`，二是更简洁高效的 `set_index().groupby().rolling().reset_index()` 链式写法；同时强调时间列必须为 `datetime64` 类型、数据需按时间排序、窗口单位（如 `'30D'`）的精确含义等易错细节，助你避开陷阱，写出健壮、可复用的时序聚合代码。

Pandas 按分组与时间列实现滚动均值的正确方法

本文详解如何在 Pandas 中对分组数据（如按 ISIN）基于时间列（如 date_x）计算时间窗口滚动均值，重点解决 ValueError: invalid on specified as date_x 错误，并提供可复用、健壮的代码方案。

本文详解如何在 Pandas 中对分组数据（如按 ISIN）基于时间列（如 date_x）计算时间窗口滚动均值，重点解决 `ValueError: invalid on specified as date_x` 错误，并提供可复用、健壮的代码方案。

在使用 Series.rolling(..., on=...) 时，on 参数要求传入的必须是 当前 Series 所属 DataFrame 的列名（字符串）、一个已存在的 Index 对象，或 None。而错误代码中：

news.groupby('ISIN')['Tone'].transform(lambda s: s.rolling('30D', on='date_x').mean())

问题在于：s 是 groupby(...)['Tone'] 返回的 Series，它本身不包含 date_x 列——该列只存在于原始 DataFrame 中。因此 s.rolling(..., on='date_x') 会因无法在 Series 内部找到 'date_x' 而抛出 ValueError。

✅ 正确做法是：先按分组，再对每个子 DataFrame 应用带 on= 的 rolling()，而非对 Series 单独调用。DataFrame.rolling(..., on=...) 支持直接指定时间列名，前提是该列已存在且为 datetime 类型（你已通过 pd.to_datetime() 完成转换，这一步很关键）。

以下是推荐的完整解决方案：

✅ 推荐写法：groupby().apply() + DataFrame.rolling()

import pandas as pd

# 构造示例数据
tone = [-0.397617, -1.217575, 0.101528, -0.736255, 1.077126]
date_x = ["2014-01-01 00:00:00", "2014-02-01 00:00:00", "2014-03-01 00:00:00", "2014-04-01 00:00:00", "2014-05-01 00:00:00"]
isin = ["DE0007664005", "DE0007664005", "DE0007664005", "DE0007664005", "DE0007664005"]

df = pd.DataFrame({'ISIN': isin, 'date_x': date_x, 'Tone': tone})
df['date_x'] = pd.to_datetime(df['date_x'])  # ✅ 必须确保为 datetime64

# 正确实现：按 ISIN 分组，对每组 DataFrame 计算基于 date_x 的 30 天滚动均值
result = (
    df.groupby("ISIN")
    .apply(
        lambda g: g.set_index('date_x')['Tone']  # 可选：设为索引更直观（非必需）
                   .rolling('30D').mean()
                   .reset_index(name='Tone_rolling_30D'),
        include_groups=False
    )
    .droplevel(0)  # 移除多余的 MultiIndex 层级（因 apply 默认保留 group key）
)

print(result)

? 输出说明：result 是一个与原始 df 行数一致的 DataFrame，新增列 Tone_rolling_30D 表示以 date_x 为时间轴、向前回溯最多 30 天的 Tone 均值（含当前行）。由于示例数据间隔为整月（≈30.4 天），实际每行仅能匹配自身（无更早数据），故首行为 NaN，后续逐行累积。

⚠️ 关键注意事项

on= 仅适用于 DataFrame 的 rolling()，不适用于 Series：务必在 groupby().apply() 中操作整个子 DataFrame，而非提取 Series 后调用 rolling()。
时间列必须为 datetime64 类型：pd.to_datetime() 不可省略；若含无效日期，需提前清洗（如 errors='coerce'）。
窗口单位含义：'30D' 表示 日历天数（calendar days），非自然月（如 '1M' 表示日历月，但精度较低，建议优先用 '30D' 或 'MS' 等明确频率）。
性能提示：对于大数据集，apply() 可能较慢。若需更高性能，可考虑 set_index('date_x').groupby('ISIN').rolling('30D')['Tone'].mean().reset_index()（注意重置索引顺序）。

✅ 替代简洁写法（推荐用于大多数场景）

# 更清晰、更高效的方式（无需 apply）
df_sorted = df.sort_values(['ISIN', 'date_x'])  # 时间序列分析前务必排序！
result = (
    df_sorted.set_index('date_x')
             .groupby('ISIN')['Tone']
             .rolling('30D').mean()
             .reset_index()
             .rename(columns={'Tone': 'Tone_rolling_30D'})
)

此写法利用了 Pandas 对 MultiIndex 的原生支持，逻辑更直观，且避免了 apply 的 Python 层开销。