在Pandas中高效计算分组变量间比率并保留原始数据

在Pandas中高效计算分组变量间比率并保留原始数据

本文详细介绍了如何在pandas dataframe中,针对特定分组(如`g1`和`g2`),计算列`tpe`中`ts`与`td`类型对应的`qc`值之比,并将结果作为新行添加回原始dataframe。教程采用`set_index`、`unstack`和`div`的向量化方法,有效处理了缺失值,确保了计算效率和结果的准确性,避免了传统`groupby().apply()`方法的潜在性能瓶颈

引言

在数据分析工作中,我们经常需要对DataFrame中的数据进行分组计算,特别是当数据以“堆叠”(stacked)形式存储时,例如将不同类型的数据作为同一列的不同行值。一个常见的需求是计算同一组内不同类型变量之间的比率,同时保留原始数据,并优雅地处理缺失值。本教程将展示一种高效且Pandas风格的解决方案,以解决此类问题。

问题描述与数据结构

假设我们有一个包含多列的DataFrame,其中G1和G2代表分组键,TPE列指示了数据的类型(例如’td’或’ts’),QC列则包含相应的值。我们的目标是:

根据G1和G2进行分组。在每个分组内,计算TPE为’ts’的QC值与TPE为’td’的QC值之比(即ts/td)。将这个比率作为一个新的行添加到原始DataFrame中,新行的TPE列应标记为’ratio’。如果某个分组中缺少’td’或’ts’中的任何一个,则对应的比率应为空(NaN)。最终输出的DataFrame应包含所有原始行以及新计算出的比率行。

以下是示例输入DataFrame df_in:

import pandas as pdimport numpy as npdata = {    'G1': ['A', 'A', 'A', 'A', 'B', 'B', 'B', 'B', 'C', 'D'],    'G2': ['S1', 'S1', 'S2', 'S2', 'S1', 'S1', 'S2', 'S2', 'S1', 'S2'],    'TPE': ['td', 'ts', 'td', 'ts', 'td', 'ts', 'td', 'ts', 'td', 'ts'],    'QC': [2, 4, 6, 3, 20, 40, 60, 30, 90, 7]}df_in = pd.DataFrame(data)# 模拟缺失值情况df_in.loc[df_in['G1'] == 'C', 'TPE'] = 'td' # 确保C只有tddf_in.loc[df_in['G1'] == 'D', 'TPE'] = 'ts' # 确保D只有tsdf_in.loc[df_in['G1'] == 'C', 'QC'] = 90df_in.loc[df_in['G1'] == 'D', 'QC'] = 7print("原始DataFrame df_in:")print(df_in)

输出 df_in:

原始DataFrame df_in:  G1  G2 TPE  QC0  A  S1  td   21  A  S1  ts   42  A  S2  td   63  A  S2  ts   34  B  S1  td  205  B  S1  ts  406  B  S2  td  607  B  S2  ts  308  C  S1  td  909  D  S2  ts   7

解决方案:向量化方法

传统的groupby().apply()方法虽然灵活,但在处理大量数据时可能效率低下,尤其是在需要将结果重新组合回原始DataFrame时。更优的方案是利用Pandas的set_index、unstack和向量化操作。

步骤一:数据重塑 (set_index 和 unstack)

首先,我们将G1、G2和TPE设置为索引,然后对TPE进行unstack操作。这将把’td’和’ts’从行值转换为列名,并将QC列的值填充到相应的位置。

# 将G1, G2, TPE设置为索引,并对TPE进行unstack操作,获取QC列的值tmp = df_in.set_index(['G1', 'G2', 'TPE']).unstack()['QC']print("n中间DataFrame tmp (unstack后):")print(tmp)

输出 tmp:

中间DataFrame tmp (unstack后):TPE   td    tsG1 G2         A  S1  2.0   4.0   S2  6.0   3.0B  S1 20.0  40.0   S2 60.0  30.0C  S1 90.0   NaND  S2  NaN   7.0

可以看到,unstack操作自动将缺失的’td’或’ts’值填充为NaN,这正是我们处理缺失比率所需要的。

步骤二:计算比率

在重塑后的tmp DataFrame中,’td’和’ts’已经成为了独立的列。现在,我们可以直接对这两列进行向量化除法操作来计算比率。

算家云 算家云

高效、便捷的人工智能算力服务平台

算家云 37 查看详情 算家云

# 计算 ts/td 的比率ratio_series = tmp['ts'].div(tmp['td'])print("n计算出的比率 Series:")print(ratio_series)

输出 ratio_series:

计算出的比率 Series:G1  G2A   S1    2.0    S2    0.5B   S1    2.0    S2    0.5C   S1    NaND   S2    NaNdtype: float64

这里,NaN值的传播是自动且正确的:如果td或ts中的任何一个为NaN,或者td为零,结果都将是NaN。

步骤三:重塑比率结果并添加TPE列

为了将比率结果与原始DataFrame合并,我们需要将其转换回与原始数据相似的格式。这包括将多级索引G1, G2重置为列,并将比率值命名为QC,同时添加一个TPE列并赋值为’ratio’。

# 将比率 Series 转换为 DataFrame,重置索引,并将比率列命名为'QC'ratio_df = ratio_series.reset_index(name='QC')# 添加TPE列,标记为'ratio'ratio_df = ratio_df.assign(TPE='ratio')print("n比率DataFrame (待合并):")print(ratio_df)

输出 ratio_df:

比率DataFrame (待合并):  G1  G2   QC    TPE0  A  S1  2.0  ratio1  A  S2  0.5  ratio2  B  S1  2.0  ratio3  B  S2  0.5  ratio4  C  S1  NaN  ratio5  D  S2  NaN  ratio

步骤四:合并原始数据与比率数据

最后一步是使用pd.concat将原始DataFrame df_in与新生成的ratio_df合并。

# 合并原始DataFrame和比率DataFramedf_out = pd.concat([df_in, ratio_df], ignore_index=True)print("n最终输出DataFrame df_out:")print(df_out)

输出 df_out:

最终输出DataFrame df_out:   G1  G2    TPE   QC0   A  S1     td  2.01   A  S1     ts  4.02   A  S2     td  6.03   A  S2     ts  3.04   B  S1     td 20.05   B  S1     ts 40.06   B  S2     td 60.07   B  S2     ts 30.08   C  S1     td 90.09   D  S2     ts  7.010  A  S1  ratio  2.011  A  S2  ratio  0.512  B  S1  ratio  2.013  B  S2  ratio  0.514  C  S1  ratio  NaN15  D  S2  ratio  NaN

完整代码示例

将上述步骤整合到一起,得到简洁高效的解决方案:

import pandas as pdimport numpy as np# 原始DataFrame设置data = {    'G1': ['A', 'A', 'A', 'A', 'B', 'B', 'B', 'B', 'C', 'D'],    'G2': ['S1', 'S1', 'S2', 'S2', 'S1', 'S1', 'S2', 'S2', 'S1', 'S2'],    'TPE': ['td', 'ts', 'td', 'ts', 'td', 'ts', 'td', 'ts', 'td', 'ts'],    'QC': [2, 4, 6, 3, 20, 40, 60, 30, 90, 7]}df_in = pd.DataFrame(data)# 模拟缺失值情况 (确保C只有td,D只有ts)df_in.loc[df_in['G1'] == 'C', 'TPE'] = 'td'df_in.loc[df_in['G1'] == 'D', 'TPE'] = 'ts'df_in.loc[df_in['G1'] == 'C', 'QC'] = 90df_in.loc[df_in['G1'] == 'D', 'QC'] = 7# 解决方案核心代码tmp = df_in.set_index(['G1', 'G2', 'TPE']).unstack()['QC']ratio_df = tmp['ts'].div(tmp['td']).reset_index(name='QC').assign(TPE='ratio')df_out = pd.concat([df_in, ratio_df], ignore_index=True)print("最终结果 df_out:")print(df_out)

注意事项与总结

效率优势: 这种基于set_index().unstack().div()的向量化方法通常比groupby().apply()更高效,尤其是在处理大型数据集时,因为它避免了Python级别的循环。缺失值处理: unstack操作会自动为缺失的组合生成NaN,而div操作会正确地将NaN传播到比率结果中,无需额外的手动检查。数据类型: QC列的数据类型在计算比率后可能会变为浮点数,因为除法运算通常会产生浮点数。pd.concat会根据需要自动调整列的数据类型。可读性: 尽管链式操作可能看起来复杂,但一旦理解了set_index和unstack的工作原理,这种方法在Pandas中是非常直观和惯用的。

通过采用这种方法,我们能够以一种既高效又健壮的方式,在Pandas DataFrame中计算分组变量间的比率,并灵活地将结果集成回原始数据结构。

以上就是在Pandas中高效计算分组变量间比率并保留原始数据的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/594222.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年11月10日 17:20:25
下一篇 2025年11月10日 17:25:08

相关推荐

  • python pexpect模块是什么?

    pexpect模块用于自动化交互式命令行程序,其核心是expect机制,通过等待特定输出并发送响应实现控制,常用于自动登录、文件传输等场景,支持spawn启动进程、expect等待提示、sendline输入内容及interact交还控制权,主要适用于Unix/Linux系统,Windows需借助扩展…

    2025年12月15日
    000
  • python中的对数log函数如何表示?

    答案是使用math模块或numpy库计算对数,math提供log、log10、log(x,base)用于单个值,numpy提供log、log10、log2用于数组运算,需确保输入大于0。 在 Python 中,对数函数可以通过标准库 math 模块或 numpy 库来实现。常用的是自然对数、以 10…

    2025年12月15日
    000
  • python集合中的操作符有哪些?怎么用?

    Python集合支持|(并集)、&(交集)、-(差集)、^(对称差集)操作符,用于简洁执行集合运算,如a|b得{1,2,3,4,5},a&b得{3},a-b得{1,2},a^b得{1,2,4,5},均返回新集合而不修改原集合。 Python集合支持多种操作符,用于执行常见的集合运算,…

    2025年12月15日
    000
  • Python中msgpack库如何使用?

    msgpack是一种高效的二进制序列化格式,比JSON更小更快,适用于网络通信和缓存存储。通过pip install msgpack安装,使用packb()/unpackb()进行内存中数据的序列化与反序列化,支持dict、list、str、int等基本类型。可使用dump()/load()操作文件…

    2025年12月15日
    000
  • python check函数如何使用?

    答案:check函数是自定义函数,用于验证条件。1. 检查数据类型或范围,如check_age验证年龄是否为0-150的整数。2. 使用os.path检查文件是否存在。3. 检查字符串是否包含关键词。4. 结合异常处理,如check_positive抛出错误提示。 Python 中并没有一个叫 ch…

    2025年12月15日 好文分享
    000
  • python列表推导式是什么意思?

    列表推导式是Python中创建列表的简洁方法,1. 通过[表达式 for 变量 in 可迭代对象 if 条件]语法实现;2. 可替代传统for循环生成如平方数列表;3. 支持条件筛选,如保留偶数平方;4. 适用于数据转换与过滤,提升代码可读性和效率。 列表推导式是 Python 中一种简洁、高效地创…

    2025年12月15日
    000
  • 优化SpaCy Matcher模式匹配:理解与应用greedy参数解决长度冲突

    本教程深入探讨了SpaCy `Matcher`在处理重叠模式时可能遇到的匹配长度冲突问题。当存在多个模式,其中一个模式是另一个模式的子集时,`Matcher`默认行为可能导致较短模式优先匹配,从而阻止更长、更具体的模式被识别。文章详细介绍了如何通过`Matcher.add()`方法中的`greedy…

    2025年12月15日
    000
  • 高效合并大量数据文件的策略:绕过解析实现快速连接

    处理大量数据文件时,直接使用数据帧库的合并功能(如polars的`read_ipc`配合`rechunk=true`)可能因数据解析和内存重分块而导致性能瓶颈。本文介绍了一种绕过完整数据解析、直接在文件系统层面进行内容拼接的策略,以显著加速文件合并过程,并探讨了针对apache arrow等特定格式…

    2025年12月15日
    000
  • Poetry new 命令行为变更:项目初始化不再自动生成测试文件

    poetry的`new`命令自2021年4月起已变更其项目初始化行为。现在,执行`poetry new`不再自动创建`test_*.py`测试文件,并且`__init__.py`文件默认为空。这一变化旨在提供更灵活的初始化方式,开发者应参照最新官方文档,并根据项目需求手动配置测试结构,以确保项目遵循…

    2025年12月15日
    000
  • 使用Python PDDL框架构建旅行商问题:Effect表达式的正确姿势

    本文旨在指导用户在使用`pddl` python框架构建旅行商问题(tsp)时,如何正确处理pddl动作的`effect`表达式。通过分析常见的`recursionerror`,揭示了将pddl逻辑表达式误用字符串拼接的错误,并提供了使用框架内置逻辑运算符(如`&`和`~`)来组合谓词的正确…

    2025年12月15日
    000
  • Python中利用自定义类实现分层字符串常量与点符号路径自动构建

    本文深入探讨如何在python中优雅地组织分层字符串常量,尤其适用于http端点路径等场景。通过自定义`endpoint`类,我们能够实现类似点符号的层级访问,并自动构建完整的路径字符串,显著提升代码的可读性、可维护性及开发效率。 在构建需要与分层API(如RESTful服务)交互的Python客户…

    2025年12月15日
    000
  • 精通Django角色与权限管理:构建灵活的访问控制系统

    django提供强大的用户、组和权限系统,可用于实现精细的角色访问控制。本文将深入探讨如何利用django的内置功能,结合自定义逻辑,为不同用户角色(如经理、普通用户)分配差异化的数据访问权限,特别是如何实现部门级数据隔离,确保系统安全与业务需求。我们将从模型设计、组与权限配置,到视图层的数据过滤,…

    2025年12月15日
    000
  • python中如何实现自动化操纵浏览器?

    Selenium库可用于Python中自动化操纵浏览器,支持Chrome、Firefox等,通过安装selenium包和对应驱动实现;示例包括打开百度、定位搜索框输入“Python”并提交;常用操作有元素定位、点击、输入、获取页面信息及等待机制;可通过ChromeOptions设置无头模式运行;尽管…

    2025年12月15日
    000
  • 从Google Drive下载并解压ZIP文件至Colab Notebook

    本教程详细介绍了如何在Google Colab环境中,无需挂载Google Drive,从公共Google Drive链接下载并解压ZIP文件。文章分析了常见的`BadZipFile`错误原因,提供了使用`requests`库构建正确下载URL的方法,并重点推荐了更便捷、鲁棒的`gdown`库,以确…

    2025年12月15日
    000
  • 从HTML表单获取逗号分隔值:转换为NumPy数组并用于机器学习预测

    本教程详细讲解了如何处理从HTML表单获取的逗号分隔字符串,将其正确转换为NumPy数值数组,并解决机器学习模型预测时常见的数组形状错误。通过字符串解析、类型转换和数组重塑,确保输入数据符合模型要求,实现准确预测。 从HTML表单获取逗号分隔值的挑战与解决方案 在Web应用开发中,我们经常需要从用户…

    2025年12月15日
    000
  • python中self可以在函数中使用吗?

    在类的方法中使用self来引用当前实例对象,它必须作为方法的第一个参数,用于访问实例属性和方法。例如,定义Person类时,通过self.name存储名字,并在greet方法中用self.name读取该值输出问候语。调用p.greet()时Python自动传入self,无需手动传递。注意self是约…

    2025年12月15日
    000
  • 如何使用python实现图片处理?

    首先安装Pillow、OpenCV、numpy和matplotlib库;接着用Pillow进行图像打开、调整大小、转灰度、滤镜等基础操作;然后使用OpenCV读取图像,转灰度图并进行边缘检测;最后通过matplotlib显示结果或保存处理后的图像,注意颜色通道顺序差异。 用Python处理图片主要依…

    2025年12月15日
    000
  • Python 环境搭建从入门到进阶的完整流程

    首先安装Python官方解释器并添加至PATH,验证版本后使用venv创建虚拟环境隔离依赖,通过pip管理包并导出requirements.txt,推荐用VS Code或PyCharm开发,配合black、flake8等工具提升代码质量,科学计算项目可选Conda管理多环境与重型库。 选择并安装 P…

    2025年12月15日
    000
  • python中exec()函数如何执行表达式?

    exec()用于执行Python语句如赋值、函数定义等,不返回结果,适合动态执行代码块;而表达式求值应使用eval(),因exec()设计上不返回表达式值,存在安全风险需谨慎使用。 exec() 函数在 Python 中用于动态执行 Python 代码,但它不能直接执行表达式并返回结果。它主要用于执…

    2025年12月15日
    000
  • python中try except语句块怎么用?

    try except用于捕获异常防止程序崩溃;2. 可指定异常类型精准处理;3. else在无异常时执行,finally始终执行用于清理;4. as可获取异常信息便于调试;5. 应合理使用避免滥用。 在 Python 中,try except 语句块用于捕获和处理程序运行时可能出现的异常,避免程序因…

    2025年12月15日
    000

发表回复

登录后才能评论
关注微信