Pandas 2.0中GroupBy.apply慢因默认纯Python执行、无JIT/向量化;提速需绕过apply,改用agg配合@numba.jit预编译函数并手动切片数组。

为什么默认的 apply 在 Pandas 2.0 GroupBy 上慢得反常
因为 Pandas 2.0 默认仍用纯 Python 解释执行 apply,哪怕你传的是一个简单循环——它不会自动 JIT 编译,也不会向量化。尤其当分组数多、每组数据少、函数逻辑含条件分支时,开销全花在 Python 调用栈和对象创建上,而不是计算本身。
常见症状:df.groupby('key').apply(lambda x: np.sum(x['val']) > 0) 比直接 df.groupby('key')['val'].sum() > 0 慢 5–10 倍;自定义函数里带 for 或 if 就更明显。
- 不是数据量大才慢,是“每组调用一次 Python 函数”这个模式本身成本高
-
agg传字典或命名元组时,若值是自定义函数,依然走apply路径 - Pandas 2.0 的
engine='numba'仅支持部分内置聚合(如sum、mean),不支持任意apply
怎么让自定义聚合函数真正用上 Numba 加速
核心:绕过 apply,改用 agg + 预编译的 numba.jit 函数,并确保输入是 NumPy 数组而非 Pandas Series。
- 必须用
@numba.jit(nopython=True, parallel=False)装饰函数,且函数只操作np.ndarray - GroupBy 后不能直接传该函数给
agg,要先用df.groupby(...).obj.values提取底层数组,再配合groupby.indices手动切片 - 推荐封装成独立工具函数,例如:
import numba import numpy as np <p>@numba.jit(nopython=True) def custom_agg_numba(vals: np.ndarray, starts: np.ndarray, ends: np.ndarray) -> np.ndarray: out = np.empty(len(starts), dtype=np.float64) for i in range(len(starts)): s, e = starts[i], ends[i] chunk = vals[s:e] out[i] = np.sum(chunk) / (np.max(chunk) - np.min(chunk) + 1e-8) return out
- 调用时需配合
pd.core.groupby.generic.SeriesGroupBy._mgr获取索引映射(不推荐)或更稳的方式:grouped = df.groupby('key'); indices = list(grouped.indices.values()),再拼成starts/ends
engine='numba' 参数在哪能用、效果如何
它只在少数明确支持的聚合方法中生效,比如 sum、mean、std、var,且仅适用于数值列、无缺失值场景。一旦列含 NaN 或类型为 object,Pandas 会静默回退到 Python 实现,不报错也不提示。
仅使用 Python 将 Claw Code 虚拟化框架与 OpenClaw 集成,提供 184 种工具和 200 多条命令,用于安全分析和代码质量...
立即学习“Python免费学习笔记(深入)”;
- 正确写法:
df.groupby('key')['col'].sum(engine='numba')—— 这会触发 Numba 编译并缓存 - 错误写法:
df.groupby('key').agg({'col': 'sum'}, engine='numba')——engine不被agg字典接口识别 - 性能差异:在百万行、千组数据下,
sum(engine='numba')比默认快 2–3 倍;但若列有 5% 以上NaN,基本没提升 - 注意:Numba 引擎不支持
axis=1或多级索引下的复杂重采样
实际项目中最容易漏掉的三个细节
加速失败往往不是代码写错,而是环境或数据形态没对齐。
- Numba 编译是 per-function + per-dtype 的,
custom_agg_numba(np.array([1,2], dtype=np.int64))和...dtype=np.float32会被当成两个函数分别编译,别指望一次编译通吃 - Pandas 2.0 默认启用
copy_on_write=True,如果你在 Numba 函数里试图原地修改传入数组,会触发隐式拷贝,反而拖慢速度——一律按只读处理 - Windows 上若用 conda 安装 numba,需确认
llvmlite版本与 numba 匹配(Pandas 2.0.3 + numba 0.57+ 要求 llvmlite 0.40+),不匹配会导致NotImplementedError: Failed in nopython mode
真要用好 Numba 加速 GroupBy,得接受“写两套逻辑”的现实:一套给小数据/调试用纯 Python,一套给大数据走 Numba 手动索引切片——没有银弹,只有权衡。


















