如何在Python中通过Batch批处理提升数据库写入吞吐?

落萱酱_6420

落萱酱_6420

2026-11-14

933人浏览

原创

batch_size并非越大越好,需兼顾数据库连接数、内存限制及参数上限;PostgreSQL建议控制在500–2000,避免单条SQL超1000组VALUES,并配合synchronous_commit=off等服务端调优。

如何在python中通过batch批处理提升数据库写入吞吐?

batch_size 不是越大越好,得看数据库连接和内存的承受力

直接把 batch_size 设成 10000 看似很爽,但常导致 MemoryError 或数据库连接超时。PostgreSQL 默认单次参数上限是 65535 个绑定变量,MySQL 的 max_allowed_packet 默认才 4MB——插 5000 条含 JSON 字段的记录就可能触发截断或报错 Packet too large。

实操建议:

  • 先用小批量(如 batch_size=100)跑通逻辑,再逐步加到 500–2000 区间测试
  • 对 PostgreSQL,避免单条 INSERT ... VALUES (...), (...), ... 超过 1000 组,否则解析开销陡增
  • 用 psutil.Process().memory_info().rss 监控写入时内存增长,超过 500MB 就该降 batch

用 executemany() 还是 execute() + VALUES tuple?关键看驱动和方言

很多人以为 executemany() 天然更快,但实际在 psycopg2(PostgreSQL)里它本质还是拼 SQL;而 MySQLdb / PyMySQL 对 executemany() 有预编译优化,但 SQLite 的 executemany() 反而比手拼 VALUES 慢 20%+(因额外循环开销)。

实操建议:

  • PostgreSQL:优先用 execute("INSERT INTO t (a,b) VALUES %s", tuples) 配合 psycopg2.extras.execute_values()
  • MySQL:确认驱动版本 ≥ 1.1.0 后,executemany() 可安全使用,但需设 cursor.execute("SET SESSION wait_timeout = 28800") 防超时
  • 避免在循环里反复调用 execute() 插单条——哪怕加了 commit() 延迟,I/O 次数仍是瓶颈

autocommit=False 是基础,但 commit 时机必须手动控制

默认 autocommit=False 只是起点,如果每插 100 条就 conn.commit(),事务日志刷盘太频繁;但如果等全部写完再 commit,崩溃就全丢。更糟的是某些 ORM(如 SQLAlchemy ORM)默认每 session.add() 都隐式 flush,根本没走批量路径。

Biopython
Biopython

全面的分子生物学工具集。适用于序列操作、文件解析(FASTA/GenBank/PDB)、系统发育分析,以及通过 Bio.Entrez 以编程方式访问 NCBI/

下载

实操建议:

  • 显式关闭 autocommit:conn.autocommit = False,然后自己决定 commit 频率
  • 按时间窗口或记录数双控:比如“每 500 条或 2 秒钟 commit 一次”,用 time.time() 记上一次 commit 时间
  • 绕过 ORM 直接用原始 cursor(conn.cursor()),避免 SQLAlchemy 的 bulk_insert_mappings() 在大数据量下反因对象构造拖慢 3–5 倍

别忽略数据库端配置,Python 写得再快也卡在 WAL 或锁上

Python 层 batch 提升了网络和解析效率,但 PostgreSQL 的 WAL 写入、MySQL 的 binlog 刷盘、以及行锁等待,才是真正的吞吐天花板。曾见一个批量插入卡在 LockWaitTimeout,查出来是另一进程在对同一张表做 ALTER TABLE。

实操建议:

  • PostgreSQL:临时调大 checkpoint_timeout 和 max_wal_size,插入前执行 SET synchronous_commit = off(接受小概率丢数据)
  • MySQL:插入前设 SET unique_checks=0, foreign_key_checks=0,完事后恢复(仅限导入可信数据)
  • 确保目标表没有冗余索引——每多一个索引,batch 写入就要多做一次 B-tree 插入,5 个索引能让吞吐跌 40%

真正卡住的地方往往不在 Python 代码里,而在你没查过的 pg_stat_activity 或 SHOW PROCESSLIST 输出中。

Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

python 数据库

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

2023.07.20

1911

4

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

2023.07.25

5384

7

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.07.31

1869

3

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

2023.08.03

32777

23

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

3867

5

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

3867

5

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

1263

5

python合并两个列表
python合并两个列表

Python是一种强大的编程语言,具有许多方便的功能和工具。在Python中,有多种方法可以合并两个列表。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.10

616

4

python是前端还是后端
python是前端还是后端

Python属于前端也属于后端,其灵活性和丰富的生态系统使得开发人员能够在不同的领域中灵活运用。本专题为大家提供python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

3003

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程