PySpark中从现有列右侧提取可变长度字符创建新列的教程

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

PySpark中从现有列右侧提取可变长度字符创建新列的教程

2025-12-01

浏览次数：次

返回列表

PySpark中从现有列右侧提取可变长度字符创建新列的教程

本教程详细介绍了如何在pyspark dataframe中，从现有列的右侧，根据特定模式（如连字符后的数字部分）提取可变长度的字符串并创建新列。文章将重点讲解如何利用`pyspark.sql.functions.regexp_extract`函数结合正则表达式，高效且灵活地实现这一数据处理需求，并提供详细的代码示例与注意事项。

PySpark中基于模式提取可变长度字符串并创建新列

在数据处理和分析中，我们经常需要从现有的字符串列中提取特定部分来生成新的特征列。当需要提取的部分长度不固定，且其位置由某种模式（例如，分隔符后的内容）决定时，常规的固定长度截取方法往往力不从心。本文将介绍在PySpark环境中，如何利用强大的正则表达式功能，结合regexp_extract函数，优雅地解决这一挑战。

场景描述

假设我们有一个PySpark DataFrame，其中包含一个名为Product的列。该列的字符串格式为“产品名称 - 数字编码”，其中产品名称和数字编码的长度都是可变的，且可能包含多个连字符，但我们总是希望提取最后一个连字符后的纯数字部分作为新的UPC列。

原始数据示例：

Product	Name
abcd - 12	abcd
xyz - 123543	xyz
xyz - abc - 123456	xyz - abc

期望输出示例：

Product	UPC
abcd - 12	12
xyz - 123543	123543
xyz - abc - 123456	123456

传统方法面临的挑战

一些用户可能会尝试使用length、locate和substring等函数来计算连字符的位置和字符串长度，进而截取所需部分。例如：

# 尝试使用 substring 组合函数 (可能导致复杂性和错误)
# df4 = df3.withColumn("LastHyphen", length(col("PRODUCT")) - locate('-', reverse(col("PRODUCT"))))
# df4 = df4.withColumn("ProductLength", length(col("PRODUCT")))
# df4 = df4.withColumn("UPC", substring("PRODUCT", df4.LastHyphen, df4.ProductLength - df4.LastHyphen))
# 这种方法在处理列类型参数时可能遇到 'Column is not iterable' 等类型错误，
# 且逻辑复杂，难以应对更复杂的模式匹配。

这种方法不仅实现起来较为繁琐，需要多步计算，而且在处理动态计算的列作为substring函数的参数时，可能会遇到类型不匹配或迭代器相关的错误。更重要的是，它对模式的适应性较差，一旦模式稍有变化，就需要大幅修改逻辑。

解决方案：使用 regexp_extract

PySpark提供了pyspark.sql.functions.regexp_extract函数，它允许我们使用正则表达式从字符串中提取匹配特定模式的部分。这对于处理可变长度、基于模式的字符串提取任务非常高效和灵活。

regexp_extract函数的语法为：regexp_extract(col, pattern, idx)。

ChatGPT Writer

免费 Chrome 扩展程序，使用 ChatGPT AI 生成电子邮件和消息。

106 查看详情 ChatGPT Writer

col: 要操作的字符串列。
pattern: 用于匹配的正则表达式字符串。
idx: 如果正则表达式包含捕获组（用括号()定义），则此参数指定要提取哪个捕获组的内容。0表示提取整个匹配项，1表示提取第一个捕获组，依此类推。

示例代码

首先，我们创建一个示例DataFrame：

from pyspark.sql import SparkSession
from pyspark.sql import Row
from pyspark.sql.functions import col, regexp_extract

# 初始化SparkSession
spark = SparkSession.builder.appName("ExtractVariableLengthSubstring").getOrCreate()

# 创建示例数据
data = [
    Row(product="abcd - 12", name="abcd"),
    Row(product="xyz - 123543", name="xyz"),
    Row(product="xyz - abc - 123456", name="xyz - abc"),
    Row(product="no hyphen product", name="no hyphen"), # 演示无匹配情况
    Row(product="product - only text", name="text after hyphen") # 演示非数字情况
]
df = spark.createDataFrame(data)

print("原始DataFrame:")
df.show()

输出：

原始DataFrame:
+-------------------+-----------------+
|            product|             name|
+-------------------+-----------------+
|          abcd - 12|             abcd|
|       xyz - 123543|              xyz|
| xyz - abc - 123456|        xyz - abc|
|  no hyphen product|        no hyphen|
|product - only text|text after hyphen|
+-------------------+-----------------+

接下来，我们应用regexp_extract来提取UPC：

# 定义正则表达式
# ".* - ([0-9]{1,})" 的解释:
# .*        : 匹配任意字符（除了换行符）零次或多次。这会贪婪地匹配到最后一个 " - " 之前的所有内容。
#  -        : 匹配字面量 " - "（一个空格，一个连字符，一个空格）。
# ([0-9]{1,}): 这是一个捕获组。
#   [0-9]   : 匹配任何数字 (0-9)。
#   {1,}    : 匹配前面的元素（即数字）一次或多次。
#            因此，这个捕获组会匹配最后一个 " - " 之后的一个或多个数字。
# 我们需要提取第一个捕获组的内容，所以 idx 为 1。
upc_pattern = r".* - ([0-9]{1,})"

# 使用 withColumn 和 regexp_extract 创建新列
df_with_upc = df.withColumn("UPC", regexp_extract(col("product"), upc_pattern, 1))

print("提取UPC后的DataFrame:")
df_with_upc.show()

# 停止SparkSession
spark.stop()

输出：

提取UPC后的DataFrame:
+-------------------+-----------------+------+
|            product|             name|   UPC|
+-------------------+-----------------+------+
|          abcd - 12|             abcd|    12|
|       xyz - 123543|              xyz|123543|
| xyz - abc - 123456|        xyz - abc|123456|
|  no hyphen product|        no hyphen|      |
|product - only text|text after hyphen|      |
+-------------------+-----------------+------+

从结果可以看出，对于不符合模式的行（如no hyphen product和product - only text），regexp_extract会返回一个空字符串，这是其默认行为。

注意事项

正则表达式的精准性：正则表达式是解决此类问题的核心。一个设计良好的正则表达式能够准确捕获目标数据，同时避免意外匹配。.*是贪婪匹配，它会尽可能多地匹配字符，这在这里确保我们匹配到的是最后一个连字符。
捕获组索引：确保regexp_extract的第三个参数idx正确指向你希望提取的捕获组。0代表整个匹配项，1代表第一个捕获组。
模式不匹配的处理：当源字符串不符合正则表达式模式时，regexp_extract将返回一个空字符串。在实际应用中，你可能需要进一步处理这些空值，例如使用when和otherwise函数进行条件赋值，或者进行数据清洗。
性能考量：正则表达式匹配通常比简单的字符串操作（如substring、split）计算成本更高。对于大规模数据集，如果性能成为瓶颈，应评估其影响。然而，对于大多数模式匹配和提取任务，regexp_extract通常是效率和灵活性的最佳平衡点。
转义字符：在Python字符串中定义正则表达式时，使用原始字符串（前缀r，例如r"pattern"）可以避免反斜杠\的二次转义问题。

总结

在PySpark中，当需要从字符串列中提取可变长度、基于复杂模式的子字符串时，pyspark.sql.functions.regexp_extract函数结合正则表达式是功能强大且高效的首选方案。它不仅简化了代码逻辑，提高了可读性，而且能够灵活应对各种复杂的字符串解析需求。通过精确构建正则表达式，我们可以轻松地从非结构化或半结构化的文本数据中提取出有价值的信息，为后续的数据分析和建模奠定基础。

以上就是PySpark中从现有列右侧提取可变长度字符创建新列的教程的详细内容，更多请关注其它相关文章！

# 不符合 # 巴基斯坦推广网站叫什么 # 贺州seo公司甄选火星 # seo佬杰 # 网站如何优化流程设计 # 化妆刷店如何营销产品推广 # 昆明短视频seo # 大冶seo优化服务好 # 行业网站建设广告公司 # 江北大型网站建设方案 # 安阳关键词排名价格查询 # 如何处理 # 如何使用 # python # 多个 # 这一 # 的是 # 第一个 # 数据处理 # 串列 # 字符串解析 # 数据清洗 # session # app # 编码 # 正则表达式