Python生成器入门:用“按需生产”思维处理海量数据
bigegpt 2025-05-05 14:12 4 浏览
想象你要制作1000个蛋糕:
- 列表的做法:先把1000个蛋糕全做好堆在厨房里,占满空间还容易变质
- 生成器的做法:有人下单时才做一个蛋糕,厨房永远只有1个蛋糕,不占空间还新鲜
这就是Python生成器的核心逻辑——按需生成数据,绝不提前囤积。本文将用漫画式思维和极简代码,带新手彻底理解这个“内存救星”。
一、为什么列表处理大数据会“卡爆”?
案例:生成1亿个数字
# 用列表存储1亿个数字(灾难现场!)
big_list = [i for i in range(100000000)] # 电脑可能直接卡死
问题根源:
- 列表像一个“超级仓库”,必须把所有数据一次性存进去
- 数据量越大,仓库越占空间,小电脑根本扛不住!
二、生成器:数据界的“自动贩卖机”
生成器就像一台自动贩卖机:
- 你按下按钮(调用next())
- 贩卖机现做一份零食(生成一个数据)
- 绝不提前生产堆在机器里
1. 生成器表达式:贩卖机的简易版
语法:
(数据生成规则 for 原材料 in 供应列表) # 用()代替列表的[]
示例:生成1-5的平方贩卖机
square_gen = (x**2 for x in range(1, 6)) # 先造一台贩卖机,不生产任何数据
如何买零食?
print(next(square_gen)) # 按下按钮:得到1(贩卖机生产第1个数据)
print(next(square_gen)) # 再按按钮:得到4(生产第2个数据)
# 每次调用next(),贩卖机才生产一个数据,内存始终只有1个数据!
2. 生成器函数:贩卖机的定制版
如果需要复杂的生产流程(如筛选、计算),可以用函数造贩卖机:
语法:
def 贩卖机函数():
for 原材料 in 供应列表:
if 原材料符合条件:
yield 加工后的产品 # yield是“出货口”,每次出一个产品后暂停
示例:生成100以内的偶数贩卖机
def even_gen():
for x in range(100):
if x % 2 == 0:
yield x # 出货口:给我一个偶数!
gen = even_gen() # 造好贩卖机
print(next(gen)) # 0(第1次出货)
print(next(gen)) # 2(第2次出货)
三、生成器的超能力:内存占用永不爆炸
实验对比:列表vs生成器的内存消耗
数据量 | 列表占用内存(Python实测) | 生成器占用内存 |
10个数字 | 约0.04KB | 约0.0008KB |
100万个数字 | 约40KB | 约0.0008KB |
1亿个数字 | 约4000KB(4MB) | 约0.0008KB |
原因:
- 列表:存1亿个数字 → 每个数字占4字节 → 总内存4亿字节=40MB
- 生成器:只存“从0开始,每次+1”的规则 → 仅需几十字节记录规则
四、生成器的3个经典使用场景
场景1:处理超大文件(如10GB日志)
传统方法(错误示范):
with open('big.log', 'r') as f:
lines = f.readlines() # 把10GB文件全读进内存,电脑直接罢工!
生成器方法(正确做法):
def read_large_file(file_path):
with open(file_path, 'r') as f:
for line in f: # 文件对象本身就是生成器,逐行读取
yield line.strip() # 每次只存1行数据,内存稳如老狗!
# 逐行处理:统计包含"ERROR"的行数
error_count = 0
for line in read_large_file('big.log'):
if "ERROR" in line:
error_count += 1
场景2:实时生成数据(如模拟传感器)
import time
def live_sensor():
while True:
yield time.strftime("%H:%M:%S") # 无限生成当前时间
time.sleep(1) # 每秒生成1个数据
# 使用:打印实时时间,不存历史数据
sensor = live_sensor()
print(next(sensor)) # 15:30:01
print(next(sensor)) # 15:30:02
# 内存始终只存最新1个时间,绝不积压!
场景3:数据流水线(过滤→转换→分析)
# 生成器链:数据像流水一样逐个处理
def generate_data():
yield 1; yield 2; yield 3; yield 4 # 生成原始数据
def filter_even(data):
for x in data:
if x % 2 == 0:
yield x # 过滤偶数
def convert_to_str(data):
for x in data:
yield f"数字{x}" # 转换格式
# 流水线:生成→过滤→转换
pipeline = convert_to_str(filter_even(generate_data()))
for item in pipeline:
print(item) # 输出:"数字2", "数字4"
五、新手必看!生成器的3个“不能做”
不能做1:用索引访问生成器
gen = (x for x in range(5))
print(gen[2]) # 报错!生成器不能像列表一样用索引
# 正确做法:用for循环遍历或next()逐个获取
不能做2:重复使用耗尽的生成器
gen = (x for x in range(3))
print(next(gen)) # 0
print(next(gen)) # 1
print(next(gen)) # 2
print(next(gen)) # 报错!生成器已空
# 解决办法:重新创建生成器对象 gen = (x for x in range(3))
不能做3:用生成器存储需要反复访问的数据
# 错误场景:需要多次遍历数据
gen = (x for x in range(5))
print(sum(gen)) # 10(第一次遍历,生成器耗尽)
print(sum(gen)) # 0(第二次遍历,没有数据了!)
# 正确做法:用列表存储需要反复使用的数据
lst = [x for x in range(5)]
print(sum(lst)) # 10
print(sum(lst)) # 10(列表数据一直都在)
六、实战练习:用生成器计算10000以内的质数
需求:生成10000以内的所有质数,要求内存占用小于1MB
步骤1:定义质数判断函数
def is_prime(n):
if n < 2:
return False
for i in range(2, int(n**0.5)+1):
if n % i == 0:
return False
return True
步骤2:用生成器函数生成质数
def prime_generator(max_num):
for n in range(2, max_num+1):
if is_prime(n):
yield n # 是质数就出货!
步骤3:遍历生成器并统计
primes = prime_generator(10000)
print(f"10000以内的质数有:{list(primes)}")
# 内存占用:生成器全程仅存储当前判断的数字,远小于1MB!
总结:生成器的“三句口诀”
- 列表是仓库,生成器是流水线:列表存所有数据,生成器逐个造数据
- 用for循环替代next():for x in 生成器: 比手动调用next()更简单
- 大数据用生成器,小数据用列表:处理几万个数据用列表,百万级数据用生成器
给新手的练习建议:
- 用生成器表达式生成1-100的奇数序列
- 尝试用生成器函数实现斐波那契数列(提示:用a, b = b, a+b)
- 思考:如何用生成器处理CSV文件的逐行解析?
生成器是Python中“聪明处理数据”的关键工具,学会它能让你在处理大数据时游刃有余。下次我们将深入迭代器原理,揭开生成器背后的神秘面纱,记得关注哦!
相关推荐
- 得物可观测平台架构升级:基于GreptimeDB的全新监控体系实践
-
一、摘要在前端可观测分析场景中,需要实时观测并处理多地、多环境的运行情况,以保障Web应用和移动端的可用性与性能。传统方案往往依赖代理Agent→消息队列→流计算引擎→OLAP存储...
- warm-flow新春版:网关直连和流程图重构
-
本期主要解决了网关直连和流程图重构,可以自此之后可支持各种复杂的网关混合、多网关直连使用。-新增Ruoyi-Vue-Plus优秀开源集成案例更新日志[feat]导入、导出和保存等新增json格式支持...
- 扣子空间体验报告
-
在数字化时代,智能工具的应用正不断拓展到我们工作和生活的各个角落。从任务规划到项目执行,再到任务管理,作者深入探讨了这款工具在不同场景下的表现和潜力。通过具体的应用实例,文章展示了扣子空间如何帮助用户...
- spider-flow:开源的可视化方式定义爬虫方案
-
spider-flow简介spider-flow是一个爬虫平台,以可视化推拽方式定义爬取流程,无需代码即可实现一个爬虫服务。spider-flow特性支持css选择器、正则提取支持JSON/XML格式...
- solon-flow 你好世界!
-
solon-flow是一个基础级的流处理引擎(可用于业务规则、决策处理、计算编排、流程审批等......)。提供有“开放式”驱动定制支持,像jdbc有mysql或pgsql等驱动,可...
- 新一代开源爬虫平台:SpiderFlow
-
SpiderFlow:新一代爬虫平台,以图形化方式定义爬虫流程,不写代码即可完成爬虫。-精选真开源,释放新价值。概览Spider-Flow是一个开源的、面向所有用户的Web端爬虫构建平台,它使用Ja...
- 通过 SQL 训练机器学习模型的引擎
-
关注薪资待遇的同学应该知道,机器学习相关的岗位工资普遍偏高啊。同时随着各种通用机器学习框架的出现,机器学习的门槛也在逐渐降低,训练一个简单的机器学习模型变得不那么难。但是不得不承认对于一些数据相关的工...
- 鼠须管输入法rime for Mac
-
鼠须管输入法forMac是一款十分新颖的跨平台输入法软件,全名是中州韵输入法引擎,鼠须管输入法mac版不仅仅是一个输入法,而是一个输入法算法框架。Rime的基础架构十分精良,一套算法支持了拼音、...
- Go语言 1.20 版本正式发布:新版详细介绍
-
Go1.20简介最新的Go版本1.20在Go1.19发布六个月后发布。它的大部分更改都在工具链、运行时和库的实现中。一如既往,该版本保持了Go1的兼容性承诺。我们期望几乎所...
- iOS 10平台SpriteKit新特性之Tile Maps(上)
-
简介苹果公司在WWDC2016大会上向人们展示了一大批新的好东西。其中之一就是SpriteKitTileEditor。这款工具易于上手,而且看起来速度特别快。在本教程中,你将了解关于TileE...
- 程序员简历例句—范例Java、Python、C++模板
-
个人简介通用简介:有良好的代码风格,通过添加注释提高代码可读性,注重代码质量,研读过XXX,XXX等多个开源项目源码从而学习增强代码的健壮性与扩展性。具备良好的代码编程习惯及文档编写能力,参与多个高...
- Telerik UI for iOS Q3 2015正式发布
-
近日,TelerikUIforiOS正式发布了Q32015。新版本新增对XCode7、Swift2.0和iOS9的支持,同时还新增了对数轴、不连续的日期时间轴等;改进TKDataPoin...
- ios使用ijkplayer+nginx进行视频直播
-
上两节,我们讲到使用nginx和ngixn的rtmp模块搭建直播的服务器,接着我们讲解了在Android使用ijkplayer来作为我们的视频直播播放器,整个过程中,需要注意的就是ijlplayer编...
- IOS技术分享|iOS快速生成开发文档(一)
-
前言对于开发人员而言,文档的作用不言而喻。文档不仅可以提高软件开发效率,还能便于以后的软件开发、使用和维护。本文主要讲述Objective-C快速生成开发文档工具appledoc。简介apple...
- macOS下配置VS Code C++开发环境
-
本文介绍在苹果macOS操作系统下,配置VisualStudioCode的C/C++开发环境的过程,本环境使用Clang/LLVM编译器和调试器。一、前置条件本文默认前置条件是,您的开发设备已...
- 一周热门
- 最近发表
- 标签列表
-
- mybatiscollection (79)
- mqtt服务器 (88)
- keyerror (78)
- c#map (65)
- resize函数 (64)
- xftp6 (83)
- bt搜索 (75)
- c#var (76)
- mybatis大于等于 (64)
- xcode-select (66)
- httperror403.14-forbidden (63)
- logstashinput (65)
- hadoop端口 (65)
- dockernetworkconnect (63)
- esxi7 (63)
- vue阻止冒泡 (67)
- c#for循环 (63)
- oracle时间戳转换日期 (64)
- jquery跨域 (68)
- php写入文件 (73)
- java大写转小写 (63)
- kafkatools (66)
- mysql导出数据库 (66)
- jquery鼠标移入移出 (71)
- 取小数点后两位的函数 (73)