百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT知识 > 正文

Python 数据分析——利用Pandas进行分组统计

liuian 2025-05-02 11:47 46 浏览

话说天下大势,分久必合,合久必分。数据分析也是如此,我们经常要对数据进行分组与聚合,以对不同组的数据进行深入解读。本章将介绍如何利用Pandas中的GroupBy操作函数来完成数据的分组、聚合以及统计。

一、分组、应用和聚合

“分而治之”(Divide and Conquer)方法(又称为“分治术”),是有效算法设计中普遍采用的一种技术。所谓“分而治之”,就是把一个复杂的算法问题按一定的“分解”方法分为等价的规模较小的若干部分,然后逐个解决,分别找出各部分的解,把各部分的解组成整个问题的解。这种朴素的思想来源于人们生活与工作的经验,也完全适用于技术领域。以海量数据处理为例,由于数据量太大,导致无法在较短时间内迅速解决,或无法一次性装入内存。那么如何解决该问题呢?无非只有一个办法——大而化小。规模太大,就把规模大的化为规模小的,各个击破。例如,从海量日志数据中提取出某日访问次数最多的那个IP,把整个大文件映射为1000个小文件,再找出每个小文件中出现频率最高的IP及相应的频率,然后从这1000个最大的IP中,找出那个频率最高的IP,即为所求。这也是大数据编程模型MapReduce的基本思想。

Pandas中同样存在着“分而治之”的思想,即Pandas的GroupBy,从英文的字面意义上理解就是“根据(By)一定的规则进行分组(Group)”。它的作用就是通过一定的规则将一个数据集划分成若干个小的区域,然后针对若干个小区域进行数据处理。简单地说,GroupBy就是Split-Apply-Combine,如图1所示。首先将数据按照不同的key进行分割(Split),然后将求和函数sum()应用(Apply)于各组,最后再将数据合并(Combine)到一起,得到最终结果。

图1 Split-Apply-Combine

二、Pandas中的GroupBy操作

本节主要以Seaborn中自带的tips数据集为例对GroupBy进行讲解。数据前5行内容如下。

2.1单列数据分组统计

以tips数据集为例,如果想按照不同性别来对数据进行统计,应该怎么办呢?首先我们需要创建一个DataFrameGroupBy对象,代码如下。

此时我们得到的只是一个DataFrameGroupBy对象,也就是只完成了图1中的Split工作,接下来要做的是Apply和Combine。例如,我们想知道tips分组里面男性(Male)和女性(Female)各有多少,代码如下。

size()即是DataFrameGroupBy对象提供的一个分组聚合函数,该函数将自动统计Male组和Female组中的数据大小,之后将其汇总到一个新的Series中,可以通过如下代码进行验证。

上面的第二段代码对分组对象中的组依次进行了遍历。除了对组进行遍历,我们还可以通过get_group()函数来获取指定组,例如:

在完成分组后,我们就可以针对各组进行聚合运算。例如,我们想看tips数据集中男性、女性买单时总账单、小费以及用餐人数的均值,那么可以采用如下代码。

上述代码对分组中每列都进行聚合运算,有的时候我们只需要对某一列进行聚合运算。例如,我们只想统计男性组与女性组的总账单均值,可以采用如下代码。

DataFrameGroupBy对象除了提供了前面已经用过的聚合函数外,还提供了如下的聚合函数。

· sum():求和

· mean():求平均值

· count():统计所有非空值

· size():统计所有值

· max():求最大值

· min():求最小值

· std():计算标准差

这里重点讲一下size()和count()的区别。有如下数据:

如果分别使用size()和count()这两个聚合函数,得到的结果将不同。

得到不同结果的原因是由于count()函数不会统计空值,而size()函数只是统计组的大小,不管取值是否为空。除了直接对分组对象使用聚合函数来完成分组统计,我们还可以使用agg()或aggregate()函数来进行分组统计,例如下面的代码与使用mean()函数效果完全一样。

既然两者效果一样,为什么Pandas中要提供agg()函数呢?这是因为agg()函数提供了更好的灵活性,我们如果想同时统计各分组的小费均值、最小值、最大值,只需要执行一次agg()函数就可以完成,代码如下。

其中,agg()函数中的参数['mean','min','max']即是聚合函数列表。此外,我们还可以对聚合后的列进行重命名,例如:

与前一段代码不同的是,这里以元组的方式来指定聚合函数。例如,('tip_mean','mean')代表了我们要执行的聚合函数为mean,聚合运算后得到的列名为tip_mean。如果完成聚合后,想将Index去掉,那么可以直接使用reset_index()函数,代码如下。

2.2多列数据分组统计

上一小节是将sex列作为分组基准,如果想同时基于sex列和day列进行分组统计男女每天的消费,可采用如下代码。

上述两段代码分别统计了tips数据集中男性与女性每天总就餐次数以及账单总额。与2.1节类似,我们也可以利用如下代码对聚合后的列进行重命名,如图2所示。

图2 重命名结果

Pandas的分组统计还提供了更加灵活的方式,对于分组后的对象,我们还可以针对不同的列进行不同聚合运算。例如针对tip列和total_bill列,我们想统计不同的内容,那么可以采用如下代码。

统计结果如图3所示。

图3 统计结果

输出数据出现了多级Index,可以用如下代码验证。

其中,第一级Index为tip和total_bill,第二级则是avg_tip、max_tip、avg_bill。如果我们想对其进行修改,可以直接利用修改列名的方式来完成,代码如下。

2.3使用自定义函数进行分组统计

如果Pandas中提供的聚合函数不能满足我们的要求,我们还可以自己编写自定义函数来完成聚合功能。例如,我们想统计男性组与女性组中账单最大值和最小值的差异,可以利用如下代码完成。


上述代码定义了一个lambda函数来完成各组中账单最大值与最小值差的计算。除了对某列进行聚合运算,还可以对不同列定义不同的自定义函数,示例如下。

lambda函数通常用于相对简单的函数定义,如果是复杂一点的,我们可以自己定义新函数后使用。如下代码定义了一个名为max_deviation()的函数。

上述代码中max_deviation()函数的参数s实际对应于分组对象的tip列,因此s.mean()是对该列求平均。在有的情况下,自定义函数还可以带参数,如果我们想知道男性和女性组总账单中金额为30~60的比例,可以采用如下代码。

上述代码中bill_between()函数中的参数,直接通过agg(bill_between,30,60)函数传入。

2.4数据过滤与变换

有的时候我们对数据进行分组不是为了分组统计,而是为了对数据进行过滤或变换,此时可以使用filter()和transform()函数来完成。例如,我们想知道tips数据集中每天消费总额大于20的账单,代码如下。

数据过滤结果如图4所示。

图4 数据过滤

上述代码首先对数据按day进行分组,x['total_bill'].mean()20将过滤消费总额大于20的数据。如果我们需要对分组数据进行变换,则使用transform()函数。例如,如下代码对按day分组的数据求均值后,将其作为新列添加回原来的df_tips中,结果如图5所示。

图7.5 数据变换

除了filter()和transform()操作,我们也可以对组对象执行apply操作。例如,我们可以按性别分组后计算小费占总账单的比例,代码如下。

相关推荐

eino v0.4.5版本深度解析:接口类型处理优化与错误机制全面升级

近日,eino框架发布了v0.4.5版本,该版本在错误处理、类型安全、流处理机制以及代理配置注释等方面进行了多项优化与修复。本次更新共包含6个提交,涉及10个文件的修改,由2位贡献者共同完成。本文将详...

SpringBoot异常处理_springboot异常注解

在SpringBoot中,异常处理是构建健壮、可维护Web应用的关键部分。良好的异常处理机制可以统一返回格式、提升用户体验、便于调试和监控。以下是SpringBoot中处理异常的完整指...

Jenkins运维之路(Jenkins流水线改造Day02-1-容器项目)

这回对线上容器服务器的流水线进行了一定的改造来满足目前线上的需求,还是会将所有的自动化脚本都放置到代码库中统一管理,我感觉一章不一定写的完,所以先给标题加了个-1,话不多说开干1.本次流水线的流程设计...

告别宕机!零基础搭建服务器监控告警系统!小白也能学会!

前言本文将带你从零开始,一步步搭建一个完整的服务器指标监控与邮件告警系统,使用的技术栈均为业界主流、稳定可靠的开源工具:Prometheus:云原生时代的监控王者,擅长指标采集与告警规则定义Node_...

httprunner实战接口测试笔记,拿走不谢

每天进步一点点,关注我们哦,每天分享测试技术文章本文章出自【码同学软件测试】码同学公众号:自动化软件测试码同学抖音号:小码哥聊软件测试01开始安装跟创建项目pipinstallhttprunne...

基于JMeter的性能压测平台实现_jmeter压测方案

这篇文章已经是两年前写的,短短两年时间,JMeter开源应用技术的发展已经是翻天覆地,最初由github开源项目zyanycall/stressTestPlatform形成的这款测试工具也开始慢...

12K+ Star!新一代的开源持续测试工具!

大家好,我是Java陈序员。在企业软件研发的持续交付流程中,测试环节往往是影响效率的关键瓶颈,用例管理混乱、接口调试复杂、团队协作不畅、与DevOps流程脱节等问题都能影响软件交付。今天,给大家...

Spring Boot3 中分库分表之后如何合并查询

在当今互联网应用飞速发展的时代,数据量呈爆发式增长。对于互联网软件开发人员而言,如何高效管理和查询海量数据成为了一项关键挑战。分库分表技术应运而生,它能有效缓解单库单表数据量过大带来的性能瓶颈。而在...

离线在docker镜像方式部署ragflow0.17.2

经常项目上会出现不能连外网的情况,要怎么使用ragflow镜像部署呢,这里提供详细的步骤。1、下载基础镜像根据docker-compose-base.yml及docker-compose.yml中的i...

看,教你手写一个最简单的SpringBoot Starter

何为Starter?想必大家都使用过SpringBoot,在SpringBoot项目中,使用最多的无非就是各种各样的Starter了。那何为Starter呢?你可以理解为一个可拔插式...

《群星stellaris》军事基地跳出怎么办?解决方法一览

《群星stellaris》军事基地跳出情况有些小伙伴出现过这种情况,究竟该怎么解决呢?玩家“gmjdadk”分享的自己的解决方法,看看能不能解决。我用英文原版、德语、法语和俄语四个版本对比了一下,结果...

数据开发工具dbt手拉手教程-03.定义数据源模型

本章节介绍在dbt项目中,如何定义数据源模型。定义并引入数据源通过Extract和Load方式加载到仓库中的数据,可以使用dbt中的sources组件进行定义和描述。通过在dbt中将这些数据集(表)声...

docker compose 常用命令手册_docker-compose init

以下是DockerCompose常用命令手册,按生命周期管理、服务运维、构建配置、扩缩容、调试工具分类,附带参数解析、示例和关键说明,覆盖多容器编排核心场景:一、生命周期管理(核心命令...

RagFlow与DeepSeek R1本地知识库搭建详细步骤及代码实现

一、环境准备硬件要求独立显卡(建议NVIDIAGPU,8GB显存以上)内存16GB以上,推荐32GB(处理大规模文档时更高效)SSD硬盘(加速文档解析与检索)软件安装bash#必装组件Docker...

Docker Compose 配置更新指南_docker-compose配置

高效管理容器配置变更的最佳实践方法重启范围保留数据卷适用场景docker-composeup-d变更的服务常规配置更新--force-recreate指定/所有服务强制重建down→up流程...