在Pandas中高效计算分组堆叠数据框中的变量比率

在Pandas中高效计算分组堆叠数据框中的变量比率

本教程详细介绍了如何在pandas数据框中,针对特定分组(如g1和g2)内的变量(如tpe列中的’ts’与’td’)计算比率,并将结果作为新行添加回原数据框。文章通过一个实际案例,展示了如何利用`set_index`、`unstack`和向量化操作,以高效且优雅的方式处理数据重塑、比率计算以及缺失值(nan)的填充,避免了传统`groupby().apply()`方法可能存在的性能瓶颈和复杂性。

数据框中分组比率计算的挑战与解决方案

在数据分析中,我们经常需要根据数据框中的某些列进行分组,然后计算组内特定变量之间的比率。例如,在一个包含交易类型(TPE)和数量(QC)的数据框中,我们可能需要计算每组(G1, G2)中’ts’类型数量与’td’类型数量的比率(ts/td)。此外,还需要将计算出的比率作为新行添加到原始数据框中,并且要妥善处理那些不包含完整’ts’和’td’值的组。

初始数据结构

假设我们有以下Pandas 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[8, 'TPE'] = 'td' # C S1 只有 tddf_in.loc[9, 'TPE'] = 'ts' # D S2 只有 tsdf_in = df_in.drop(index=[8,9]).append(pd.DataFrame([['C', 'S1', 'td', 90], ['D', 'S2', 'ts', 7]], columns=df_in.columns), ignore_index=True)print("原始数据框 df_in:")print(df_in)

输出 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

目标输出

我们的目标是生成一个包含原始数据和计算出的比率的新数据框 df_out。对于每个 (G1, G2) 组,如果同时存在 ‘td’ 和 ‘ts’ 类型的 QC 值,则计算 ts_QC / td_QC 作为比率,并将新行的 TPE 列标记为 ‘ratio’。如果缺少 ‘td’ 或 ‘ts’,则比率应为空(NaN)。

期望的 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

传统 groupby().apply() 方法的局限性

一种常见的思路是使用 groupby().apply() 方法,为每个组编写一个自定义函数来计算比率。

def calculate_ratio_apply(group):    td_row = group[group['TPE'] == 'td']    ts_row = group[group['TPE'] == 'ts']    if not td_row.empty and not ts_row.empty:        ratio = ts_row['QC'].values[0] / td_row['QC'].values[0]        return pd.DataFrame({'G1': [group['G1'].iloc[0]],                              'G2': [group['G2'].iloc[0]],                              'TPE': ['ratio'],                              'QC': [ratio]})    # 如果缺少td或ts,返回一个空的DataFrame,这会导致这些组的比率行被省略    return pd.DataFrame() # 这种方法会忽略没有完整td和ts值的组# grouped = df_in.groupby(['G1', 'G2']).apply(calculate_ratio_apply).reset_index(drop=True)# df_out_apply = pd.concat([df_in, grouped], ignore_index=True)# print("n使用 apply 方法(可能遗漏空比率):")# print(df_out_apply)

上述 apply 方法虽然能计算比率,但如果某个组没有同时包含 ‘td’ 和 ‘ts’ 值,它会返回一个空的DataFrame,导致这些组的比率行被完全省略,而不是填充 NaN。对于大型数据集,apply 方法也可能因为循环迭代而导致性能问题。

算家云 算家云

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

算家云 37 查看详情 算家云

优化方案:利用 unstack 和向量化操作

更高效和优雅的解决方案是利用 Pandas 的数据重塑功能,将 ‘TPE’ 列中的 ‘td’ 和 ‘ts’ 值转化为独立的列,然后进行向量化计算。

# 1. 重塑数据:将 'TPE' 列中的 'td' 和 'ts' 值转换为独立的列#    - set_index(['G1', 'G2', 'TPE']): 将这三列设为索引#    - unstack()['QC']: 将 TPE 索引层的数据(QC值)unstack(逆透视)成列#      结果是一个多级索引的 DataFrame,列为 TPE 的不同值(td, ts)tmp = df_in.set_index(['G1', 'G2', 'TPE']).unstack()['QC']print("n中间结果 tmp (重塑后的数据):")print(tmp)

中间结果 tmp 的结构如下,我们可以清晰地看到每个 (G1, G2) 组对应的 ‘td’ 和 ‘ts’ 值,以及缺失值(NaN):

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
# 2. 计算比率:直接对重塑后的列进行向量化除法#    - tmp['ts'].div(tmp['td']): 计算 'ts' 列与 'td' 列的比率#    - reset_index(name='QC'): 将多级索引重置为列,并将比率结果命名为 'QC'#    - assign(TPE='ratio'): 添加一个新列 'TPE',其值为 'ratio'ratio_df = tmp['ts'].div(tmp['td']).reset_index(name='QC').assign(TPE='ratio')print("n计算出的比率数据框 ratio_df:")print(ratio_df)

计算出的比率数据框 ratio_df 如下:

  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
# 3. 合并数据:将原始数据框和计算出的比率数据框进行纵向合并df_out = pd.concat([df_in, ratio_df], ignore_index=True)print("n最终输出数据框 df_out:")print(df_out)

最终的 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# 原始数据框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 S1 只有 td,D S2 只有 tsdf_in = df_in.drop(index=[8,9]).append(pd.DataFrame([['C', 'S1', 'td', 90], ['D', 'S2', 'ts', 7]], columns=df_in.columns), ignore_index=True)# 1. 重塑数据:将 'TPE' 列中的 'td' 和 'ts' 值转换为独立的列#    通过 set_index 和 unstack,将数据从长格式转换为宽格式,便于计算tmp = df_in.set_index(['G1', 'G2', 'TPE']).unstack()['QC']# 2. 计算比率并格式化结果#    - tmp['ts'].div(tmp['td']): 执行向量化除法,自动处理缺失值(NaN)#    - reset_index(name='QC'): 将多级索引重置为常规列,并将比率结果列命名为 'QC'#    - assign(TPE='ratio'): 添加一个新列 'TPE',其值为 'ratio'ratio_df = tmp['ts'].div(tmp['td']).reset_index(name='QC').assign(TPE='ratio')# 3. 合并数据:将原始数据框和计算出的比率数据框进行纵向合并df_out = pd.concat([df_in, ratio_df], ignore_index=True)print("最终输出数据框 df_out:")print(df_out)

注意事项与总结

效率提升: 相比于 groupby().apply(),使用 set_index().unstack() 结合向量化操作(如 .div())在处理大型数据集时通常更高效,因为它利用了 Pandas 底层的优化 C 语言实现。缺失值处理: unstack() 操作会自动将缺失的数据填充为 NaN。在进行除法运算时,任何包含 NaN 的运算结果仍为 NaN,这自然地满足了对“空比率”的需求。可读性与简洁性: 这种方法代码更简洁,逻辑更清晰,避免了自定义函数中复杂的条件判断。通用性: 这种数据重塑和向量化计算的模式适用于各种需要计算分组内变量之间比率或差值等场景。

通过本教程,您应该能够高效且优雅地在 Pandas 数据框中处理分组比率计算问题,即使面对复杂的数据结构和缺失值情况也能游刃有余。

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

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

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
Scala多线程环境下的计数器线程安全问题详解
上一篇 2025年11月10日 15:53:08
什么是SQL的JOIN操作?多表连接的实现方式解析
下一篇 2025年11月10日 15:53:13

相关推荐

  • Matplotlib 地图中多类型图例的创建与优化

    Matplotlib 地图中多类型图例的创建与优化Matplotlib 地图中多类型图例的创建与优化Matplotlib 地图中多类型图例的创建与优化Matplotlib 地图中多类型图例的创建与优化

    本教程旨在解决matplotlib地图可视化中,如何在一个图例中同时展示颜色块(如区域分类)和自定义标记(如特定兴趣点)的问题。文章详细介绍了当传统`patch`对象无法正确显示标记时,如何利用`matplotlib.lines.line2d`创建标记图例句柄,并将其与颜色块图例句柄合并,从而生成一…

    2026年5月10日 用户投稿
    100
  • 比特币新手教程 比特币交易平台有哪些

    比特币是一种去中心化的数字货币,基于区块链技术实现点对点交易,具有匿名性、有限发行和不可篡改等特点;新手可通过交易所购买,P2P交易获得比特币,常用平台包括Binance、OKX和Huobi;交易流程包括注册账户、实名认证、绑定支付方式、充值法币并下单购买,可选择市价单或限价单;比特币存储方式有交易…

    2026年5月10日
    000
  • 深入理解 Express.js 中 next() 参数的作用与中间件机制

    本文深入探讨 express.js 中间件函数中的 `next()` 参数。它负责将控制权传递给请求-响应周期中的下一个中间件或路由处理程序。文章将详细解释 `next()` 的工作原理、中间件的注册与执行顺序,以及不正确使用 `next()` 可能导致请求挂起的风险,并通过代码示例和实际应用场景,…

    2026年5月10日
    000
  • Golang空接口如何应用在项目中

    空接口可用于接收任意类型值,常见于日志函数、通用数据结构、JSON动态解析及配置驱动逻辑,提升代码灵活性,但需配合类型断言确保安全,避免滥用以降低维护成本。 空接口 interface{} 在 Go 语言中是一个非常灵活的类型,它可以存储任何类型的值。虽然它牺牲了一部分类型安全,但在实际项目中合理使…

    2026年5月10日
    100
  • JavaScript计算器开发:解决数值显示与初始化问题

    本教程深入探讨了使用JavaScript构建计算器时常见的数值显示异常问题,特别是由于类属性未初始化导致的`Cannot read properties of undefined`错误。我们将详细分析问题根源,并通过在构造函数中调用初始化方法来解决该问题,同时优化显示逻辑,确保计算器功能稳定且界面显…

    2026年5月10日
    000
  • Circle为何在凌晨向Solana新增铸造5亿枚USDC?USDC增发原因与对SOL生态影响深度解析

    近日,链上数据显示,Circle 在凌晨向 Solana 链新增铸造了 5亿枚USDC。此次大规模增发引起市场关注,投资者需要了解背后的原因以及对 Solana 生态的潜在影响。 USDC增发原因分析 增发 USDC 的主要原因可能包括: 满足市场需求:近期 Solana 上交易活动活跃,USDC …

    2026年5月10日
    000
  • 基于两数组数据计算结果排序的 React 教程

    本教程针对 React 应用中需要根据两个独立数组的数据计算结果进行排序的场景,提供了一种高效的解决方案。通过使用 JavaScript 的 `reduce` 和 `map` 方法,将两个数组根据唯一标识符进行合并,从而简化排序逻辑,提高代码的可读性和可维护性。避免了复杂的嵌套循环或同步迭代,提供了…

    2026年5月10日
    000
  • Golang如何优化日志写入性能_Golang日志写入与文件IO优化方法

    使用缓冲、异步写入、高性能日志库和优化IO策略提升Golang日志性能,推荐zap+异步缓冲+SSD组合以平衡实时性、可靠性与高并发需求。 在高并发场景下,Golang程序的日志写入可能成为性能瓶颈。频繁的文件IO操作不仅影响响应速度,还可能导致系统负载升高。要提升日志写入性能,不能只依赖简单的fm…

    2026年5月10日
    000
  • CodeIgniter在IIS环境下实现URL重写与index.php移除指南

    本教程详细指导如何在IIS服务器上部署的CodeIgniter应用中,移除URL中不必要的index.php。核心解决方案涉及修改CodeIgniter的config.php文件,将$config[‘index_page’]设置为空,并辅以正确的IIS web.config重…

    2026年5月10日
    100
  • PHP安全文件下载:防止直链与保护资源

    本文旨在解决通过检查元素获取直链下载文件的问题,并提供一种安全的PHP服务器端文件交付方案。核心思想是利用PHP作为文件代理,通过设置HTTP响应头直接将文件发送给用户,从而隐藏文件的实际存储路径,有效防止未经授权的直接链接访问。 客户端下载链接的风险与局限性 在构建下载页面时,开发者常常面临一个挑…

    2026年5月10日
    100
  • 什么是合约由于流动性不足无法平仓?小币种合约的死亡陷阱

    合约因流动性不足无法平仓,表现为买卖订单稀少导致平仓指令难成交,尤其常见于小币种。1、盘口深度浅、交易时段冷清加剧平仓难度;2、低交易量与下降的未平仓量反映小币种流动性枯竭风险;3、应采用限价单分批平仓、切换至高流动性品种对冲、设置宽松止盈止损等策略应对。 binance币安交易所 注册入口: AP…

    2026年5月10日
    000
  • 比特币价格为何波动?深度解析影响BTC的五大因素

    近期比特币(btc)价格波动引起市场广泛关注,投资者纷纷寻找影响价格的关键因素。深入分析可以发现,btc价格波动主要受以下五大因素驱动: 一、宏观经济与政策影响 比特币价格对全球经济数据、货币政策和利率调整高度敏感。例如,美联储降息或量化宽松政策可能推高BTC价格,而紧缩政策则可能导致价格下行。投资…

    2026年5月10日
    100
  • Go语言中复制数组的几种方法详解

    本文介绍了在 Go 语言中复制数组和切片的几种方法,重点讲解了内置的 `copy` 函数的使用方式,以及在多维切片场景下深拷贝与浅拷贝的区别,并提供了相应的代码示例。通过本文,你将掌握在不同场景下选择合适的复制方法,避免潜在的陷阱。 在 Go 语言中,复制数组和切片是一个常见的操作。根据不同的需求,…

    2026年5月10日
    000
  • 币圈合约稳健玩法:资金管理与永续合约赚钱技巧解析

    在币圈,合约交易因其杠杆效应和双向交易特性而吸引大量投资者,但风险也较高。本文将解析如何通过资金管理和永续合约操作实现稳健收益,帮助投资者在波动市场中科学操作。 永续合约与资金管理核心概念 永续合约是一种无到期日的合约交易工具,投资者可通过做多或做空获利。稳健操作的关键在于资金管理:控制每笔交易的投…

    2026年5月10日
    100
  • Python代码如何实现定时任务 Python代码使用Schedule模块的配置

    答案:使用Python的schedule模块可实现定时任务,通过try-except处理异常确保程序不中断,结合threading实现多线程任务避免阻塞,利用JSON文件保存和加载任务配置实现持久化。 使用Python实现定时任务,主要依赖于schedule模块,它提供了一种简单易懂的方式来安排周期…

    2026年5月10日
    000
  • 深入理解 Laravel Session::put:避免常见陷阱与实现表单限流

    本文旨在深入探讨 laravel 框架中 `session::put` 方法的正确用法及其常见误区。针对用户在实现表单提交限流时遇到的问题,详细阐述了 `session::put` 必须提供键值对的原理,并提供了如何在控制器中利用会话机制有效防止重复提交的实战代码示例。通过本文,读者将掌握 lara…

    2026年5月10日
    000
  • 解决React中按钮点击不显示弹出表单的问题:状态管理与语法修正

    本教程旨在解决react应用中点击按钮后弹出表单未能正确渲染的问题。核心在于识别并修正代码中的语法错误以及未定义的react状态管理函数。我们将详细探讨如何使用`usestate`等react hooks来声明和管理组件状态,确保交互逻辑的正确实现,并提供结构清晰的代码示例,帮助开发者构建功能完善的…

    2026年5月10日
    000
  • PHP代码注入检测日志分析_PHP代码注入日志检测方法详解

    答案:日志分析是发现PHP代码注入的关键手段,主要通过Web服务器访问日志、PHP错误日志、PHP-FPM日志及应用自定义日志等多源数据,结合grep、ELK、WAF等工具识别含eval()、system()、Base64编码、目录遍历等特征的异常请求,并建立基线、设置检测规则与自动化告警,配合事件…

    2026年5月10日
    000
  • HTML如何引入JS脚本_HTML script标签引入JavaScript方式

    内联JavaScript适合简单逻辑,代码直接嵌入HTML;2. 外部JS文件利于分离与复用,推荐开发使用;3. async和defer可优化加载性能,async不保证执行顺序,defer在解析完成后按序执行;4. 动态引入实现按需加载,提升效率。合理选择方式有助于提升页面性能与维护性。 在HTML…

    2026年5月10日
    000
  • C#如何进行网络编程?Socket与TCP/IP通信编程实例详解

    C#通过Socket类实现TCP通信,首先服务器绑定IP和端口并监听,客户端发起连接,双方通过Send/Receive收发数据,最后关闭连接。 C# 进行网络编程主要依赖于 System.Net 和 System.Net.Sockets 命名空间,其中最核心的是使用 Socket 类实现基于 TCP…

    2026年5月10日
    000

发表回复

登录后才能评论
关注微信