Python Pandas:高效处理多CSV文件并统计指定列唯一值

Python Pandas:高效处理多CSV文件并统计指定列唯一值

本教程详细介绍了如何使用python pandas库高效地处理多个csv文件,并统计其中指定列(例如列’b’)的唯一值数量。文章通过实际示例演示了如何读取文件、识别并计数唯一项,最终生成一份汇总表格。此外,还探讨了如何提取每个文件中首次出现的唯一值行,为数据分析提供灵活的解决方案。

在日常数据分析工作中,我们经常会遇到需要处理大量分散在多个文件中的数据。一个常见的需求是,从一系列结构相似的CSV文件中,提取并统计某个特定列(例如,用户ID、商品SKU等)的唯一值数量。本教程将指导您如何利用Python的Pandas库高效地完成这项任务,并生成一份清晰的汇总报告。

准备工作:生成示例数据

为了更好地演示,我们首先创建一些模拟的CSV文件。这些文件将具有相同的列结构,并包含随机数据。

import numpy as npimport pandas as pdfrom glob import globimport os# 清理旧的CSV文件,确保每次运行都是新的示例for f in glob('file_??.csv'):    os.remove(f)n = 1000 # 每个文件的行数columns = list('abcde') # 列名np.random.seed(0) # 设置随机种子以保证结果可复现# 生成10个CSV文件for i in range(10):    filename = f'file_{i:02d}.csv'    pd.DataFrame(        np.random.randint(0, 1000, (n, len(columns))), # 生成随机整数数据        columns=columns,    ).to_csv(filename, index=False) # 保存为CSV,不包含索引print("已生成10个示例CSV文件:file_00.csv 到 file_09.csv")

上述代码将创建10个名为 file_00.csv 到 file_09.csv 的文件,每个文件包含5列(’a’到’e’)和1000行随机数据。我们的目标是统计每个文件中列’b’的唯一值数量。

核心任务:统计每个文件的指定列唯一值

现在,我们将实现统计每个CSV文件中列’b’的唯一值数量,并将其汇总到一个Pandas DataFrame中。

立即学习“Python免费学习笔记(深入)”;

1. 文件发现与读取

首先,我们需要找到所有目标CSV文件。glob模块是Python标准库中用于查找符合特定模式的文件路径的强大工具

# 使用glob查找所有匹配模式的CSV文件filenames = glob('file_??.csv')print(f"发现以下文件:{filenames}")

glob(‘file_??.csv’) 会匹配所有以 file_ 开头,后面跟任意两个字符,并以 .csv 结尾的文件,例如 file_00.csv, file_01.csv 等。

2. 识别与计数唯一值

对于每个文件,我们将执行以下操作:

使用 pd.read_csv() 读取文件内容。利用 duplicated([‘b’]) 方法识别列’b’中的重复值。该方法返回一个布尔Series,其中 True 表示该行在列’b’上是重复的(即,之前已经出现过相同的值),False 表示是首次出现或唯一值。通过对 ~pd.read_csv(filename).duplicated([‘b’]) 进行求和,可以统计 False 的数量,这等同于列’b’的唯一值数量。

3. 构建汇总表格

我们可以使用字典推导式遍历所有文件,将文件名作为键,唯一值数量作为值,然后将这个字典转换为Pandas Series,并进一步转换为DataFrame。

# 遍历每个文件,计算列'b'的唯一值数量distinct_counts = {    filename: (~pd.read_csv(filename).duplicated(['b'])).sum()    for filename in filenames}# 将结果转换为Pandas Series,并进一步处理为DataFramedf_summary = pd.Series(distinct_counts)                .to_frame('count')                .rename_axis(index='filename')print("n每个文件列'b'的唯一值数量汇总:")print(df_summary)

输出示例:

             countfilename          file_01.csv    645file_00.csv    613file_02.csv    617file_03.csv    626file_04.csv    623file_05.csv    644file_06.csv    615file_07.csv    628file_08.csv    645file_09.csv    636

这份 df_summary DataFrame清晰地展示了每个CSV文件中列’b’的唯一值数量。

扩展应用:提取每个文件的首个唯一值行

除了统计唯一值的数量,有时我们可能还需要获取每个文件中列’b’首次出现时的完整行数据。例如,如果列’b’代表产品ID,我们可能想获取每个产品ID在文件中首次出现时的所有相关信息。

我们可以通过 drop_duplicates() 方法来实现这一目标。结合 pd.concat(),我们可以将所有文件的结果合并成一个大型DataFrame,并保留原始文件的标识。

# 提取每个文件列'b'的首个唯一值行df_distinct_rows = pd.concat([    pd.read_csv(filename).drop_duplicates(['b'])    for filename in filenames], keys=filenames) # 使用文件名作为外部索引(MultiIndex)print("n每个文件列'b'的首个唯一值行汇总:")print(df_distinct_rows)

输出示例:

                   a    b    c    d    efile_01.csv 0    689  191  884  615  649            1     24   68  794  820  107            2    566  469  718  157  897            3    206  256  527  417  672            4    765  755  741  197  926...              ...  ...  ...  ...  ...file_09.csv 986  626  622  224  726  274            988  329  900  577   26  221            990   47  800  369  567   11            998  602  198  165  217  682            999  564  982  890  126  450[6292 rows x 5 columns]

这里的 df_distinct_rows 是一个MultiIndex DataFrame,第一层索引是文件名,第二层是原始文件中的行索引。这使得我们可以方便地追溯每条记录的来源文件。

注意事项与性能考量

内存管理: 对于非常大的CSV文件,一次性读取所有文件到内存可能会导致内存溢出。在这种情况下,可以考虑使用 pd.read_csv 的 chunksize 参数分块读取,或者使用 Dask 等专门处理大数据集的库。然而,对于本教程中统计唯一值的场景,duplicated() 或 drop_duplicates() 通常需要访问整个列的数据,因此分块读取可能需要更复杂的逻辑来维护全局的唯一性状态。文件路径与模式匹配: glob 模式应准确反映您要处理的文件命名约定。如果文件分布在不同的子目录中,可能需要调整模式或使用 os.walk 进行更复杂的遍历。列名一致性: 确保所有CSV文件都包含您要分析的目标列(例如’b’),并且列名大小写一致。否则,pd.read_csv 可能会报错或返回不正确的结果。数据类型: duplicated() 和 drop_duplicates() 对不同数据类型(字符串、数字、日期等)都能很好地工作,但要确保列的数据类型在文件中是一致的。

总结

本教程演示了如何利用Python的Pandas库高效地处理多个CSV文件,以统计指定列的唯一值数量。通过 glob 模块进行文件发现,结合 pd.read_csv、duplicated() 和 sum(),我们可以轻松地生成一份汇总报告。此外,drop_duplicates() 和 pd.concat() 的组合也为提取每个文件中首次出现的唯一值行提供了强大的解决方案。掌握这些技术将大大提高您在多文件数据处理和分析中的效率。

以上就是Python Pandas:高效处理多CSV文件并统计指定列唯一值的详细内容,更多请关注创想鸟其它相关文章!

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

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
# 如何在 Jupyter Notebook 中直接读取单元格输入数据
上一篇 2025年12月14日 23:02:55
将行数据转换为列:Pandas pivot 方法详解
下一篇 2025年12月14日 23:03:02

相关推荐

  • composer require-dev和require有什么不同_Composer Require与Require-Dev区别解析

    require用于声明项目运行必需的依赖,如框架、数据库组件和第三方SDK,这些包会随项目部署到生产环境;2. require-dev用于声明仅在开发和测试阶段需要的工具,如PHPUnit、PHPStan、Faker等,不会默认部署到生产环境;3. 安装时composer install根据环境决定…

    2026年5月10日
    1000
  • Matplotlib 地图中多类型图例的创建与优化

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

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

    2026年5月10日 用户投稿
    100
  • Golang JSON序列化:控制敏感字段暴露的最佳实践

    本教程探讨golang中如何高效控制结构体字段在json序列化时的可见性。当需要将包含敏感信息的结构体数组转换为json响应时,通过利用`encoding/json`包提供的结构体标签,特别是`json:”-“`,可以轻松实现对特定字段的忽略,从而避免敏感数据泄露,确保api…

    2026年5月10日
    000
  • 利用海象运算符简化条件赋值:Python教程与最佳实践

    本文旨在探讨Python中海象运算符(:=)在条件赋值场景下的应用。通过对比传统if/else语句与海象运算符,以及条件表达式,分析海象运算符在简化代码、提高可读性方面的优势与局限性。并通过具体示例,展示如何在列表推导式等场景下合理使用海象运算符,同时强调其潜在的复杂性及替代方案,帮助开发者更好地掌…

    2026年5月10日
    100
  • Debian syslog性能优化技巧有哪些

    提升Debian系统syslog (通常基于rsyslog)性能,关键在于精简配置和高效处理日志。以下策略能有效优化日志管理,提升系统整体性能: 精简配置,高效加载: 在rsyslog配置文件中,仅加载必要的输入、输出和解析模块。 使用全局指令设置日志级别和格式,避免不必要的处理。 自定义模板: 创…

    2026年5月10日
    000
  • c++中的SFINAE技术是什么_c++模板编程中的SFINAE原理与应用

    SFINAE 是“替换失败不是错误”的原则,指模板实例化时若参数替换导致错误,只要存在其他合法候选,编译器不报错而是继续重载决议。它用于条件启用模板、类型检测等场景,如通过 decltype 或 enable_if 控制函数重载,实现类型特征判断。尽管 C++20 引入 Concepts 简化了部分…

    2026年5月10日
    000
  • RichHandler与Rich Progress集成:解决显示冲突的教程

    在使用rich库的`richhandler`进行日志输出并同时使用`progress`组件时,可能会遇到显示错乱或溢出问题。这通常是由于为`richhandler`和`progress`分别创建了独立的`console`实例导致的。解决方案是确保日志处理器和进度条组件共享同一个`console`实例…

    2026年5月10日
    000
  • Golang goroutine与channel调试技巧

    使用go run -race检测数据竞争,结合runtime.NumGoroutine监控协程数量,通过pprof分析阻塞调用栈,利用select超时避免永久阻塞,有效排查goroutine泄漏、死锁和数据竞争问题。 Go语言的goroutine和channel是并发编程的核心,但它们也带来了调试上…

    2026年5月10日
    000
  • 使用 Jupyter Notebook 进行探索性数据分析

    Jupyter Notebook通过单元格实现代码与Markdown结合,支持数据导入(pandas)、清洗(fillna)、探索(matplotlib/seaborn可视化)、统计分析(describe/corr)和特征工程,便于记录与分享分析过程。 Jupyter Notebook 是进行探索性…

    2026年5月10日
    000
  • 网站标题关键词更新后,搜索引擎为何仍显示旧标题?

    网站标题更新后,搜索引擎为何显示旧标题? 网站SEO优化中,站长常修改网站标题关键词,期望搜索结果显示自定义标题。然而,即使更新标签、meta keywords、meta description和结构化数据中的name属性后,搜索结果仍显示旧标题,这令人费解。本文将对此进行解释。 问题:站长修改了网…

    2026年5月10日
    100
  • Python命令怎样使用profile分析脚本性能 Python命令性能分析的基础教程

    使用Python的cProfile模块分析脚本性能最直接的方式是通过命令行执行python -m cProfile your_script.py,它会输出每个函数的调用次数、总耗时、累积耗时等关键指标,帮助定位性能瓶颈;为进一步分析,可将结果保存为文件python -m cProfile -o ou…

    2026年5月10日
    000
  • 如何插入查询结果数据_SQL插入Select查询结果方法

    如何插入查询结果数据_SQL插入Select查询结果方法如何插入查询结果数据_SQL插入Select查询结果方法如何插入查询结果数据_SQL插入Select查询结果方法如何插入查询结果数据_SQL插入Select查询结果方法

    使用INSERT INTO…SELECT语句可高效插入数据,通过NOT EXISTS、LEFT JOIN、MERGE语句或唯一约束避免重复;表结构不一致时可通过别名、类型转换、默认值或计算字段处理;结合存储过程可提升可维护性,支持参数化与动态SQL。 将查询结果数据插入到另一个表中,可以…

    2026年5月10日 用户投稿
    000
  • Python递归函数追踪与性能考量:以序列打印为例

    本文深入探讨了Python中一种递归打印序列元素的方法,并着重演示了如何通过引入缩进参数来有效追踪递归函数的执行流程和参数变化。通过实际代码示例,文章揭示了递归调用可能带来的潜在性能开销,特别是对调用栈空间的需求,以及Python默认递归深度限制可能导致的错误,为读者提供了理解和优化递归算法的实用见…

    2026年5月10日
    000
  • python中zip函数详解 python多序列压缩zip函数应用场景

    zip函数的应用场景包括:1) 同时遍历多个序列,2) 合并多个列表的数据,3) 数据分析和科学计算中的元素运算,4) 处理csv文件,5) 性能优化。zip函数是一个强大的工具,能够简化代码并提高处理多个序列时的效率。 在Python中,zip函数是一个非常有用的工具,它能够将多个可迭代对象打包成…

    2026年5月10日
    000
  • 谷歌浏览器如何截图 谷歌浏览器页面截图技巧

    谷歌浏览器如何截图 谷歌浏览器页面截图技巧谷歌浏览器如何截图 谷歌浏览器页面截图技巧谷歌浏览器如何截图 谷歌浏览器页面截图技巧谷歌浏览器如何截图 谷歌浏览器页面截图技巧

    使用谷歌浏览器的开发者工具截图步骤:1. 按ctrl+shift+i(windows/linux)或cmd+option+i(mac)打开开发者工具。2. 点击右上角三个点,选择”更多工具”,再选择”截图”。3. 选择截取整个页面。推荐的谷歌浏览器扩展…

    2026年5月10日 用户投稿
    100
  • Python中怎样使用pymongo?

    在python中使用pymongo可以轻松地与mongodb数据库进行交互。1)安装pymongo:pip install pymongo。2)连接到mongodb:from pymongo import mongoclient; client = mongoclient(‘mongod…

    2026年5月10日
    000
  • JS如何实现迭代器?迭代器协议

    JavaScript中实现迭代器需遵循可迭代协议和迭代器协议,通过定义[Symbol.iterator]方法返回具备next()方法的迭代器对象,从而支持for…of和展开运算符;该机制统一了数据结构的遍历接口,实现惰性求值,适用于自定义对象、树、图及无限序列等复杂场景,提升代码通用性与…

    2026年5月10日
    000
  • JavaScript函数中插入加载动画(Spinner)的正确方法

    本文旨在解决在JavaScript函数中插入加载动画(Spinner)时遇到的异步问题。通过引入async/await和Promise.all,确保在数据处理完成前后正确显示和隐藏加载动画,提升用户体验。我们将提供两种实现方案,并详细解释其原理和优势。 在Web开发中,当执行耗时操作时,显示加载动画…

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

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

    2026年5月10日
    100
  • Go语言网络编程入门:构建TCP客户端/服务器

    本文旨在为Go语言初学者提供一份简洁明了的网络编程入门指南,重点介绍如何使用TCP套接字构建简单的客户端/服务器应用。通过示例代码和注意事项,帮助读者快速上手Go语言的网络编程,并了解一些最佳实践。 Go语言对网络编程提供了强大的支持,通过标准库net包,可以轻松实现各种网络应用。本文将重点介绍如何…

    2026年5月10日
    000

发表回复

登录后才能评论
关注微信