Pandas管道操作中合并后高效创建新列的方法

---

在pandas数据处理管道中，合并（merge）操作后如何高效且简洁地利用现有列创建新列是一个常见需求。本文将深入探讨在管道中执行此类计算的正确方法，重点介绍`dataframe.eval()`方法，并解释为什么直接使用`assign()`或`transform()`可能导致类型错误，提供清晰的实现范例，以优化数据处理流程。

在数据分析和处理中，我们经常需要将多个数据集合并，然后在合并后的结果上进行进一步的计算，生成新的特征列。Pandas的管道式操作（.pipe()或链式方法调用）能够使代码更加简洁和可读。然而，在管道中合并数据后尝试使用assign()或transform()创建新列时，可能会遇到一些类型错误，尤其是在直接引用列名进行运算时。

初始数据准备

首先，我们创建两个示例DataFrame，solar_part和solar_aod，它们将通过pool列进行合并。

import pandas as pd

# 第一个DataFrame
solar_part = pd.DataFrame(
     {'pool': 1,
     'orig': 635.1}, index = [0]
     )

# 第二个DataFrame
solar_aod = pd.DataFrame(
     {'pool': [1,1,1,1],
      'MoP': [1,2,3,4],
     'prin': [113.1, 115.3, 456.6, 234.1]}
     )

print("solar_part DataFrame:")
print(solar_part)
print("\nsolar_aod DataFrame:")
print(solar_aod)

合并后的计算挑战

我们的目标是在合并solar_aod和solar_part后，创建一个名为remn的新列，其值为prin列除以orig列的结果。

尝试直接在assign()中使用列表引用列名进行计算，例如 assign(remn = ['prin'] / ['orig'])，会导致 TypeError: unsupported operand type(s) for /: 'list' and 'list'。这是因为 ['prin'] 和 ['orig'] 被解释为包含字符串的列表，而不是DataFrame的Series列。即使尝试使用字符串引用（例如 'prin' / 'orig'），也会因为字符串不支持除法操作而产生类似的错误。

# 错误的尝试：直接在assign中使用列表引用
try:
    solar_p_error = (
        solar_aod
        .merge(solar_part, on = ['pool'], how = 'left')
        .assign(remn = ['prin'] / ['orig'])
    )
except TypeError as e:
    print(f"\n捕获到错误：{e}")

解决方案：使用 DataFrame.eval()

为了在管道中优雅且高效地完成合并后的列计算，DataFrame.eval()方法是一个非常强大的工具。它允许我们使用字符串表达式来创建或修改列，Pandas会在DataFrame的上下文中解析这些表达式。

eval()的优势在于：

1. 简洁性： 可以直接用字符串形式表达复杂的列间运算。
2. 性能： 对于大型DataFrame，eval()在某些情况下比纯Python循环或NumPy操作更高效，因为它在C层面进行计算。
3. 可读性： 表达式直接反映了计算逻辑。

以下是使用eval()在合并后创建新列的正确方法：

NoCode

美团推出的零代码应用生成平台

180 查看详情

# 正确的解决方案：使用 eval()
solar_p_correct = (
    solar_aod
    .merge(solar_part, on='pool', how='left')
    .eval('remn = prin / orig')
)

print("\n使用 eval() 创建新列后的 DataFrame:")
print(solar_p_correct)

输出结果：

   pool  MoP   prin   orig      remn
0     1    1  113.1  635.1  0.178082
1     1    2  115.3  635.1  0.181546
2     1    3  456.6  635.1  0.718942
3     1    4  234.1  635.1  0.368603

在这个示例中，'remn = prin / orig' 是一个字符串表达式，eval()会识别 prin 和 orig 为DataFrame中的列，并执行相应的除法运算，将结果赋值给新列 remn。

替代方案：assign() 结合 lambda 函数

虽然 eval() 在此场景下表现出色，但 assign() 也可以通过结合 lambda 函数来完成任务。lambda 函数允许您传入DataFrame本身作为参数，从而正确地引用其列。

# 替代方案：使用 assign() 结合 lambda 函数
solar_p_lambda = (
    solar_aod
    .merge(solar_part, on='pool', how='left')
    .assign(remn = lambda df: df['prin'] / df['orig'])
)

print("\n使用 assign() 结合 lambda 创建新列后的 DataFrame:")
print(solar_p_lambda)

这种方法同样有效，但对于简单的算术表达式，eval() 的字符串语法通常更简洁直观。assign() 结合 lambda 在需要更复杂逻辑（例如条件判断、调用外部函数）时更为灵活。

注意事项与最佳实践

• 选择合适的工具： 对于基于现有列的简单算术或比较操作，DataFrame.eval() 是管道中创建新列的理想选择。它提供简洁的语法和潜在的性能优势。
• 理解 assign() 的工作方式： assign() 期望接收Series或可调用对象（如 lambda 函数），而不是直接的字符串列名或列表。当使用 lambda 时，lambda 函数会接收当前DataFrame作为参数，从而可以正确地访问列。
• 可读性优先： 在选择方法时，始终考虑代码的可读性和维护性。对于复杂的、涉及多列的计算，eval() 的字符串表达式可能比嵌套的 lambda 表达式更易读。
• 避免混合引用： 在 eval() 表达式中，列名可以直接使用，但如果要引入外部变量，需要使用 @ 符号，例如 eval('remn = prin / @my_variable')。

总结

在Pandas的数据处理管道中，合并操作后高效地创建新列是常见需求。通过本文的探讨，我们了解到DataFrame.eval()方法是处理这类任务的强大且简洁的工具，它允许我们直接使用字符串表达式进行列间计算，避免了assign()在直接引用列名时可能导致的TypeError。同时，我们也介绍了assign()结合lambda函数的替代方案，适用于更复杂的逻辑。掌握这些技巧，将有助于您编写更清晰、更高效的Pandas数据处理代码。

以上就是Pandas管道操作中合并后高效创建新列的方法的详细内容，更多请关注其它相关文章！

# 工具  # 网站seo优化的作用有哪些  # 网红营销方案推广  # 淘宝的营销推广措施  # 云南营销网站优化  # 而不是  # 串列  # 正确地  # 链式  # 可以直接  # 浮点  # 是在  # 是一个  # 道中  # 数据处理  # 为什么  # python  # 营销推广业务体系是什么  # 辽源关键词排名怎么样  # 京挑客如何做网站推广  # 裕华seo教学公司  # 郴州网站建设培训学校  # 推广营销稳定吗 

相关栏目： 【 Google疑问12 】 【 Facebook疑问10 】 【 优化推广96088 】 【 技术知识133117 】 【 IDC资讯59369 】 【 网络运营7196 】 【 IT资讯61894 】

相关推荐： AO3官方镜像链接 | 最新防走失网址永久收藏  邮政快递寄件查询入口 邮政快递收件查询入口  POKI小游戏在线免费入口链接 POKI小游戏无下载秒玩玩  晨报|开发商暗示《空洞骑士：丝之歌》DLC开发中 《合金装备4》有望重制  抖音如何进行蓝V认证 抖音企业号申请所需资料与流程  键盘测试软件哪个好_键盘故障检测工具推荐  支付宝登录刷脸不是本人如何解决  《优志愿》修改手机号方法  教资成绩怎么查询  掌握CSS :has() 选择器：父选择器、嵌套限制与常见陷阱解析  顺丰快递怎么查物流_顺丰快递物流信息实时查询操作指南  b站如何剪辑视频_b站必剪app使用教程  AO3中文版手机快速通道_AO3最新稳定链接更新  《崩坏：星穹铁道》3.6版本异相仲裁打法及配队推荐  5G和6G的连接密度有什么区别 6G每平方公里能连接多少设备  iPhone 15 Pro如何查看存储空间占用_iPhone 15 Pro存储空间查看教程  126手机126邮箱登录_126邮箱手机登录入口官网  《星露谷物语》克林特好感度事件介绍  Win10如何查看已安装的更新补丁 Win10卸载指定更新教程【教程】  PDF如何批量加注释_PDF多文件批注高亮操作教程  Python csv 模块处理非字符串数据：列表写入 CSV 文件的机制解析  《律学法考》查看学习数据方法  纯CSS实现自适应宽度与响应式布局的水平按钮组  《新三国志曹操传》游历事件袁尚突围攻略  《爱南宁》认证电动车方法  抖音小程序怎么开通？小程序开通条件是什么？  Python实战：高效处理实时数据流中的最小/最大值  小红书网页版怎么进 小红书网页版通用入口  FotoBalloon图片左右镜像教程  苹果手机缓存怎么清除_苹果手机缓存如何清除iphone各版本操作步骤  Go App Engine 项目结构与包管理深度指南  PPT智能排版生成入口 免费PPT内容自动生成平台  米侠浏览器插件无法启用怎么办 米侠浏览器扩展兼容性修复  餐馆菜篮选购指南  我居然低估了 DeepSeek，这次更新它做到了这些！  苹果手机怎么合并照片_苹果手机合并多张照片的操作方法  《360浏览器》自动保存账号密码设置方法  顺丰快递收费标准查询_如何查看顺丰最新收费价格  铁拳8在线玩 铁拳8在线秒玩入口  德邦快递收费标准详解  路由器DNS怎么设置最快 优化DNS提升上网速度教程  《华夏千秋》龙女试炼功法获取方法  excel怎么计算平均值 excel平均函数*ERAGE使用教学  PHP安全加载非公开目录图片与动态内容类型处理指南  VS Code快捷键when上下文子句的妙用  《盗墓笔记手游》技能介绍  Python类装饰器动态修改方法时的类型提示：Mypy插件实现精确静态分析  Lar*el如何创建自定义的辅助函数（Helpers）_Lar*el全局函数定义与加载方法  如何在mysql中使用索引提示_mysql索引提示优化方法  TikTok视频播放不流畅怎么办 TikTok视频播放优化方法 

 2025-11-25