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

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!

总结:生成器的“三句口诀”

  1. 列表是仓库,生成器是流水线:列表存所有数据,生成器逐个造数据
  2. 用for循环替代next():for x in 生成器: 比手动调用next()更简单
  3. 大数据用生成器,小数据用列表:处理几万个数据用列表,百万级数据用生成器

给新手的练习建议

  1. 用生成器表达式生成1-100的奇数序列
  2. 尝试用生成器函数实现斐波那契数列(提示:用a, b = b, a+b)
  3. 思考:如何用生成器处理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编译器和调试器。一、前置条件本文默认前置条件是,您的开发设备已...