
本文介绍在 polars dataframe 中准确统计字符串列中**重叠匹配**(overlapping)子串出现次数的实用方法,突破 `str.count_matches` 仅支持非重叠匹配的限制,并提供可扩展、向量化、无 python 循环的纯表达式解决方案。
在 Polars 中,pl.Expr.str.count_matches(pattern) 是统计子串出现频次的常用方法,但它基于正则引擎实现,默认行为是贪心、非重叠匹配。例如,对 "aaaaa" 查找 "aa",它会匹配位置 0–1 和 2–3,跳过 1–2 和 3–4,因此返回 2 而非期望的 4。要获得真正的重叠计数(即滑动窗口式扫描),需另辟路径。
核心思路是:将每个字符串切分为所有长度为 len(pattern) 的连续子串(即滑动窗口),再对每个子串判断是否完全等于目标模式,最后按行求和。这一过程可完全通过 Polars 表达式链完成,无需 UDF 或 Python 循环,保障性能与可扩展性。
以下是以子串 "aa" 为例的完整实现:
import polars as pl
df = pl.DataFrame({"foo": ["aaaaa", "aabaa", "aaaab"]})
pattern = "aa"
window_size = len(pattern)
# 第一步:获取所有字符串的最大长度,用于确定最大滑动窗口起始索引
max_len = df.select(pl.col("foo").str.len_chars().max()).item()
# 第二步:对每个可能的起始位置 i(0 到 max_len - window_size),切片出长度为 window_size 的子串
# 并为每个切片创建临时列(如 "0", "1", ...),值为对应子串;超出长度的自动为 null
sliced_df = df.select(
pl.col("foo").str.slice(i, window_size).alias(f"slice_{i}")
for i in range(max_len - window_size + 1)
)
# 第三步:在 sliced_df 中,对所有 slice_* 列执行 str.count_matches(pattern),结果为 1 或 0(因长度严格匹配)
# 再用 sum_horizontal 按行聚合,得到每行的重叠匹配总数
result = (
df
.with_columns(
pl.sum_horizontal(
[pl.col(f"slice_{i}").str.count_matches(pattern)
for i in range(max_len - window_size + 1)]
).alias("count")
)
)
print(result)输出:
shape: (3, 2) ┌───────┬───────┐ │ foo ┆ count │ │ --- ┆ --- │ │ str ┆ u32 │ ╞═══════╪═══════╡ │ aaaaa ┆ 4 │ │ aabaa ┆ 2 │ │ aaaab ┆ 3 │ └───────┴───────┘
✅ 关键优势说明:
- 纯表达式驱动:全程使用 Polars 原生表达式,充分利用底层 Arrow 计算优化,避免 Python GIL 和逐行迭代开销;
- 自动边界处理:str.slice(i, n) 对越界索引返回 null,而 count_matches 对 null 输入返回 null,sum_horizontal 默认忽略 null,因此无需手动填充或截断;
- 模式无关性:只需修改 pattern 变量,即可适配任意长度子串(如 "abc"、"xxy"),无需重写逻辑;
- 内存友好:虽生成中间切片列,但 Polars 采用惰性计算与零拷贝切片,实际内存占用可控。
⚠️ 注意事项:
- 当字符串极长(如 >10k 字符)且模式很短(如 "a")时,切片列数量会激增(O(n)),可能影响计划构建速度。此时建议结合 str.len_chars() 过滤超长行,或改用自定义 Rust UDF(进阶场景);
- 若需支持大小写不敏感匹配,可先统一转为小写:pl.col(...).str.to_lowercase().str.slice(...).str.count_matches(...);
- 该方法本质是“显式滑动窗口”,语义清晰、调试友好,优于正则前瞻断言((?=aa))等晦涩方案——后者在 Polars 中不仅难以调试,且 count_matches 对零宽断言的支持有限且不稳定。
总结而言,通过 str.slice 构建滑动窗口 + count_matches 单字符/单模式判等 + sum_horizontal 行聚合,我们构建了一种简洁、健壮、高性能的重叠子串计数范式。它不仅是解决当前问题的最优实践,更体现了 Polars “以列为本、表达式优先”的设计哲学。










