您的位置:首页 >聚焦 >

Mongodb数据库转换为表格文件的库

2022-03-16 12:51:48    来源:程序员客栈
点击上方“Python爬虫与数据挖掘”,进行关注

回复“书籍”即可获赠Python从入门到进阶共10本电子书

却嫌脂粉污颜色,淡扫蛾眉朝至尊。前言

大家好,我是吴老板。今天给大家分享一个可将Mongodb数据库里边的文件转换为表格文件的库,这个库是我自己开发的,有问题可以随时咨询我。

Mongo2file库是一个 Mongodb数据库转换为表格文件的库。

在我的日常工作中经常和 mongodb打交道,而从 mongodb数据库中批量导出数据为其他格式则成为了刚需。

如果您跟我一样每次导出数据时都需要重新编写或到处寻找 脚本代码的话,这个库可能会对您产生帮助。

依赖于快速 PyArrow

mongo2file依赖于 PyArrow库。它是 C++ Arrow的 Python版本实现。

PyArrow目前与 Python 3.7、3.8、3.9和 3.10兼容。

仓库地址: https://github.com/apache/arrow

如果您在 Windows上遇到任何的导入问题或错误,您可能需要安装 Visual Studio 2015。

警告: PyArrow目前只支持到 win64位 ( Python 64bit) 操作系统。

其次,除了常见的 csv、excel、以及 json文件格式之外, mongo2file还支持导出 pickle、feather、parquet的二进制压缩文件。

pickle、feather、parquet是 Python序列化数据的一种文件格式, 它把数据转成二进制进行存储。从而大大减少读取的时间。

安装

pipinstallmongo2file

基本用法快速开始

importosfrommongo2fileimportMongoEngineM=MongoEngine(host=os.getenv("MONGO_HOST","127.0.0.1"),port=int(os.getenv("MONGO_PORT",27017)),username=os.getenv("MONGO_USERNAME",None),password=os.getenv("MONGO_PASSWORD",None),database=os.getenv("MONGO_DATABASE","test_"),collection=os.getenv("MONGO_COLLECTION","test_"))defto_csv():result_=M.to_csv()assert"successfully"inresult_defto_excel():result_=M.to_excel()assert"successfully"inresult_defto_json():result_=M.to_excel()assert"successfully"inresult_defto_pickle():result_=M.to_pickle()assert"successfully"inresult_defto_feather():result_=M.to_feather()assert"successfully"inresult_defto_parquet():result_=M.to_parquet()assert"successfully"inresult_to_csv()

当 MongoEngine控制类指定了 mongodb表名称时、将对数据表 (mongodb集合) 进行导出操作。

其类方法参数包括:

query: 指定对数据表的查询参数、只对指定表名时有效folder_path: 指定导出目录路径filename: 指定导出文件名、默认为 表名称+ 当前时间_id: 指定是否导出 _id、布尔型、默认为 Falselimit: 指定导出表的限制数据、int类型、默认为 -1、即不限制。

importosfrommongo2fileimportMongoEngine"""作用于MongoEngine类未指定表名称时"""M=MongoEngine(host=os.getenv("MONGO_HOST","127.0.0.1"),port=int(os.getenv("MONGO_PORT",27017)),username=os.getenv("MONGO_USERNAME",None),password=os.getenv("MONGO_PASSWORD",None),database=os.getenv("MONGO_DATABASE","test_"))defto_csv():result_=M.to_csv()assert"successfully"inresult_defto_excel():result_=M.to_excel()assert"successfully"inresult_defto_json():result_=M.to_json()assert"successfully"inresult_to_csv()

当 MongoEngine控制类只指定了 mongodb库名称时、将对数据库下所有集合进行导出操作。

面对 mongo2file的瓶颈和改进

对于 mongodb的全表查询、条件查询、聚合操作、以及索引操作(当数据达到一定量级时建议) 并不是直接影响 数据导出的最大因素。

因为 mongodb的查询一般而言都非常快速,主要的瓶颈在于读取 数据库 之后将数据转换为大列表存入 表格文件时所耗费的时间。

_这是一件非常可怕的事情_。

当没有多线程(当然这里的多线程并不是对同一文件进行并行操作,文件写入往往是线程不安全的)、 数据表查询语句无优化时,并且当数据达到一定量级时(比如 100w行),单表单线程表现出来的效果真是让人窒息。

在 mongo2file在进行大数据量导出时表现的并没有多么优秀。导致的主要原因可能是:

采用的 xlsxwriter库写入 excel时是积极加载(非惰性)的,数据全部加载至内存后插入表格。大数据量插入表格时、跟宿主机器的性能有关。

mongo2file表现的不如人意时,我做出了一下改进:

当数据量过大时,数据表分块读取,导出多表格。增加线程池的最大并发数、当选取的 block_size值合适时,将发挥最大性能。对于数据转换一些建议对于 xlsxwriter、openpyxl、xlwings以及 pandas引用的任何引擎进行写入操作时、都会对写入数据进行非法字符的过滤。这一点从部分源码中可以看得出来。由于行数据表中可能存在 excel无法识别的非法字符 (比如空列表 []) , 当写至此行时将抛出 非法类型的错误。而比较恰当合理的做法就是在存储 mongodb文档时不要存入类似于 []、{}的这种对原始数据无意义的空对象。Reference APIMongoEngine

MongoEngine(host="localhost",port=27017,username=None,password=None,database="测试库",collection="测试表_200000")

to_csv(query, folder_path, filename, ...)

:paramquery:数据库查询条件、字典类型、只作用于单表导出:paramfolder_path:指定导出的目录:paramfilename:指定导出的文件名:param_id:是否导出_id默认否:paramlimit:限制数据表查询的条数:paramis_block:是否分块导出:paramblock_size:块大小、is_block为True时生效


to_excel(query, folder_path, filename, ...)

:paramquery:数据库查询条件、字典类型、只作用于单表导出:paramfolder_path:指定导出的目录:paramfilename:指定导出的文件名:param_id:是否导出_id默认否:paramlimit:限制数据表查询的条数:paramis_block:是否分块导出:paramblock_size:块大小、is_block为True时生效:parammode:导出模式,枚举类型、sheet或xlsx,当is_block为True时生效:paramignore_error:是否忽略错误、数据表中存在非序列化类型时使用、这将一定程度上影响程序的性能


to_json(query, folder_path, filename, ...)

:paramquery:数据库查询条件、字典类型、只作用于单表导出:paramfolder_path:指定导出的目录:paramfilename:指定导出的文件名:param_id:是否导出_id默认否:paramlimit:限制数据表查询的条数:paramis_block:是否分块导出:paramblock_size:块大小、is_block为True时生效

to_pickle(query, folder_path, filename, ...)

:paramquery:数据库查询条件、字典类型、只作用于单表导出:paramfolder_path:指定导出的目录:paramfilename:指定导出的文件名:param_id:是否导出_id默认否:paramlimit:限制数据表查询的条数

to_feather(query, folder_path, filename, ...)

:paramquery:数据库查询条件、字典类型、只作用于单表导出:paramfolder_path:指定导出的目录:paramfilename:指定导出的文件名:param_id:是否导出_id默认否:paramlimit:限制数据表查询的条数

to_parquet(query, folder_path, filename, ...)

:paramquery:数据库查询条件、字典类型、只作用于单表导出:paramfolder_path:指定导出的目录:paramfilename:指定导出的文件名:param_id:是否导出_id默认否:paramlimit:限制数据表查询的条数

总结

大家好,我是吴老板。以上就是今天要分享的全部内容了,总的来说,Mongo2file库是一个可以将 Mongodb数据库转换为表格文件的库,不仅支持导出csv、excel、以及 json文件格式, 还支持导出 pickle、feather、parquet的二进制压缩文件。欢迎大家积极尝试,在使用过程中有遇到任何问题,欢迎随时联系我。

最后感谢【吴老板】提供的mongo2file库,也欢迎大家积极尝试使用,如果有遇到问题,请随时联系我,希冀在实际工作中帮到大家,那样就锦上添花了。

小伙伴们,快快用实践一下吧!如果在学习过程中,有遇到任何问题,欢迎加我好友,我拉你进Python学习交流群共同探讨学习。

-------------------End-------------------

往期精彩文章推荐:

如何把一个python列表(有很多个元素)变成一个excel表格的第一列?

盘点使用Pandas解决问题:对比两列数据取最大值的5个方法

盘点Python正则表达式中的贪婪模式和非贪婪模式

Jsrpc学习——加密参数Sign变化的网站破解教程

欢迎大家点赞,留言,转发,转载,感谢大家的相伴与支持

想加入Python学习群请在后台回复【入群】

万水千山总是情,点个【在看】行不行

/今日留言主题/

随便说一两句吧~

关键词: 文件格式 数据转换 大数据量

相关阅读