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

1分钟插入10亿行数据!抛弃Python,写脚本请使用Rust

yuyutoo 2024-12-27 17:35 2 浏览 0 评论

来源:Avinash

编辑:好困

【新智元导读】近日,一位程序员急需在一分钟之内生成十亿行的测试数据库,然而在用Python写了脚本之后发现「大失败」。怎么办?当然是用Rust了!


最近,一位程序员表示自己急需一个「也就」十亿行数据的测试数据库,并且还得在一分钟之内生成。


于是,他做了一个所有程序员都会做的事:写一个Python脚本来生成数据库。


然而,很不幸的是,这个脚本非 常 慢



于是,他又做了一个所有程序员都会做的事:进一步学习关于SQLite、Python以及不知道为什么还有Rust的知识。


项目已开源:https://github.com/avinassh/fast-sqlite3-inserts


目标

作者需要在他2019年的MacBook Pro(2.4GHz四核i5)上,一分钟内生成一个有10亿行的SQLite数据库


表的模式


要求:


  1. 生成的数据是随机的;
  2. 「area」列将包含六位数的地区代码(任何六位数都可以,不需要验证);
  3. 「age」列是5、10或15中的任何一个;
  4. 「active」列是0或1。


不过,作者表示,对脚本的要求也不用太高,还是可以妥协的:


  1. 如果进程崩溃,所有的数据都丢失也没有问题,再次运行脚本就可以了;
  2. 允许充分利用电脑的资源:100%的CPU,8GB的内存和剩余的SSD储存;
  3. 不需要使用真正的随机方法,来自stdlib的伪随机方法就可以。


Python原型

在最开始的脚本中,作者试图在一个for循环中逐一插入1000万条记录,而这让用时直接达到了15分钟



显然,这太慢了。


在SQLite中,每次插入都是一个事务,每个事务都保证它被写入磁盘,作者推断可能问题就来自这里。


于是作者开始尝试不同规模的批量插入,发现10万是一个最佳点,而运行时间减少到了10分钟



SQLite优化

作者认为自己写的代码已经很简练了,并没有什么可以优化的空间。


于是他将下一个目标转到了数据库的优化。


根据各种关于SQLite优化的建议,作者做了一些改进。



  • 关闭「journal_mode」将禁用回滚日志,也就是说,如果任何事务失败,都无法回滚。


  • 关闭「synchronous」,将使SQLite不再关心是否能可靠地写入磁盘,而是把这个责任交给操作系统。也就是说,可能会出现SQLite并没有成功写入磁盘的情况。


  • 「cache_size」指定了SQLite在内存中可以保留多少个内存页。


  • 当「locking_mode」为「EXCLUSIVE」模式时,SQLite锁住的连接将永远不会被释放。


  • 将「temp_store」设置为「MEMORY」可以让其表现像一个内存数据库。


此处作者提醒,请不要把这些操作用到生产上去。


重新审视Python

作者再次重写了Python脚本,这次包括了微调的SQLite参数,这次带来了巨大的提升,运行时间大幅减少:


  • 原始的for循环版本用时大约10分钟
  • 批处理版本用时大约8.5分钟


PyPy

PyPy在其主页上强调它比CPython快4倍,于是作者决定尝试一下。


令作者有些意外的是,竟然不需要对现有的代码进行任何改动,只需要在PyPy运行就可以了。


批处理版本只需要2.5分钟,也就是速度快了接近3.5倍


Busy Loop?

莫非是在Python的循环上耗费了太多时间?于是作者删除了SQL指令之后再次跑了一遍代码:


  • 批处理版本在CPython中用时5.5分钟


  • 批处理版本在PyPy中用时1.5分钟(又是3.5倍的速度提升)。


然而用Rust重写了相同的内容之后,循环只需要17秒


于是,作者果断抛弃Python转投Rust的怀抱。



Rust

像Python一样,作者先写了一个原始的Rust版本,一个循环执行一行数据的插入。


然而,即便使用了所有SQLite的优化,也依然消耗了大约3分钟。于是作者进行了进一步的测试:


  • 尝试把「rusqlite」换成异步运行的「sqlx」,这让用时直接被拉到了14分钟。作者表示,这比自己迄今为止写的任何一个Python迭代都要差。
  • 在执行原始SQL语句时,使用准备好的语句。这个版本的用时只有1分钟


最优的版本

使用准备好的语句,以50行为一个批次插入,最终用时34.3秒


作者又写了一个线程版本,其中一个线程从通道接收数据,还有四个线程向通道推送数据。


这个也是目前性能最好的版本,最终用时大约32.37秒




IO时间

SQLite论坛上的网友提出了一个有趣的想法:测量内存数据库所需的时间。


于是作者又跑了一遍代码,将数据库的位置设定为「:memory:」,rust版本完成的时间少了两秒(29秒)。


也就是说将1亿条记录写入到磁盘上需要2秒,这个用时似乎也是合理的。


这也说明,可能没有更多的SQLite优化可以以更快的方式写入磁盘,因为99%的时间都花在生成和添加数据上。


排行榜


插入1亿行数据的用时:
Rust33秒 PyPy126秒 CPython210秒


总结


  1. 尽可能使用SQLite PRAGMA语句


  1. 使用准备好的语句


  1. 进行分批插入


  1. PyPy确实比CPython快4倍


  1. 异步不一定更快


目前,第二快的版本是单线程运行的,而作者的电脑有4个核心,于是他在一分钟内可以得到8亿行数据。然后再经过几秒钟的数据合并,时间仍然可以少于一分钟。


网友评论


博主的这一番研究获得了网友们的一致好评。


真的很喜欢这些观点:

学习了更多关于PRAGMA语句。

PyPy的效率和灵活性可以通过即插即用的方式体现(将来一定会给它一个机会)。

文章的排版非常简单,有适当的源代码链接。很有趣,很容易上手。


Rust高光时刻又来了!



参考资料:

https://avi.im/blag/2021/fast-sqlite-inserts/

https://github.com/avinassh/fast-sqlite3-inserts

相关推荐

在lazarus中使用匿名线程

lazarus开源、跨平台,ide稳定、快捷和简洁,是开发国产信创最优选择。尽管lazarus脚本是FreePascal,与delphi的ObjectPascal稍不同,组件库LCL功能、外观相比...

编程金钢钻,我爱Delphi(三)

-----浅谈消息事件驱动模型和面向对象上期谈了最新版的Delphi的编程环境,小白们不要急着编程。在这之前,让我先给你们讲讲消息事件驱动模型和面向对象,作为编程的准备。当然,我会尽量讲得简单,一是我...

Delphi编程防止界面卡死的方法经验分享

Delphi编程防止界面卡死的方法经验分享!1.循环里面防止界面卡死的方法可以使用Application.ProcessMessages;例如下列方法:varn:Integer;begin...

DELPHI学习之「Hook挂钩」

一、什么是Hook挂钩函数Hook使我们可以控制系统事件的发生和处理,能够预演和修改系统事件和消息,在系统范围内阻止系统事件和消息的发生。首先,我们用SetWindowsHookEx(idHook...

Tcp Socket 编程之Delphi与其他语言的字节码通信

关键字:TcpScoket、Delphi、Indy、Python、Twisted对于TcpSocket编程,异种语言之间的通信在日常开发中经常会用到。今天,我们通过Delphi和Pyth...

重要通知!报表控件FastReport VCL将停止支持旧的 Delphi 版本

FastReport是功能齐全的报表控件,可以帮助开发者可以快速并高效地为.NET,VCL,COM,ActiveX应用程序添加报表支持,由于其独特的编程原则,现在已经成为了Delphi平台最优秀的报...

设计模式Delphi版本之单例模式-续

接上篇,细心的朋友可能发现我在上一篇文章中重写类NewInstance和FreeInstance函数,原因是:【在delphi中编译器对构造函数的保护级别进行了处理,即便设为private,编译器仍然...

Delphi基础教程图文版之字符串详解

上午在整理多线程的文章,没注意时间今天发晚了,最近争取日更!!Delphi中的字符一直处于懵懵懂懂的状态,不同于我接触到的其它编程语言在Delphi中居然有好几种字符串,今天好好研究一番!!Delph...

Delphi Event Bus 2.1发布了

DelphiEventBus这个开源项目发布了,这是我用到的最好的开源项目,强烈推荐给大家。前期也有写过这方面的文章,如果你还不知道,可以学习一下,这里不多说了,这个版本改动不大,但意义重大,使...

在 aardio 中嵌入 Delphi 控件

这个例子我放到范例里了:运行这个范例,会自动检测Delphi编写的DLL是否存在,不存在会自动打开Delphi工程,也就是这个文件:...

DELPHI学习之「COM+编程」

COM和ActiveX概述COM技术,是微软公司力推的一项非常重要的开发技术,既是当前软件开发领域的一项技术标准,又是很多高级开发领域的,可能唯一的实现方式。比如:流媒体开发所用到的Direct...

DELPHI学习之「OmniThreadLibrary库」

OmniThreadLibrary是Delphi下的一款用于多线程并发处理的程序库。它的目标是让多线程编程更流畅,成为真正的多线程编程的“可视化”库。它与TThread的区别是让用户专注于线程开发中的...

delphi中关于多线程的例子

在Delphi中使用多线程,我们可以使用`TThread`类来实现。以下是利用Delphi中的多线程的一些例子:1.使用TThread类创建一个简单的匿名线程:varThread:...

Delphi基础教程图文版之线程控制

这个好像并没有什么需要特别说明的东西,所谓的控制包括但不限于启动、暂停、停止和通讯。通讯问题放在后面讲解线程同步时处理Delphi对于多线程的控制同样提供了两套不同的处理方式TThread线程类...

DELPHI学习之「多线程编程」

线程的挂起:要用到Suspend方法来挂起线程线程唤醒:Resume方法来唤醒线程线程终止:利用线程类的Terminate方法来中止线程...

取消回复欢迎 发表评论: