我用 Python 处理3万多条数据,只要几秒钟……
我用 Python 处理3万多条数据,只要几秒钟……
前言
本文的文字及图片来源于网络,仅供学习、交流使用,不具有任何商业用途,版权归原作者所有,如有问题请及时联系我们以作处理。
作者:鼠
PS:如有需要Python学习资料的小伙伴可以加点击下方链接自行获取http://t.cn/A6Zvjdun
应用场景:工作中经常遇到大量的数据需要整合、去重、按照特定格式导出等情况。如果用 Excel 操作,不仅费时费力,还不准确,有么有更高效的解决方案呢?
本文以17个 txt 文本,3万多条数据为例,使用 Python 连接 MySQL 数据库,实现快速操作。公众号后台回复“3万”获取数据和源代码。
本文主要包括以下三方面内容:
- 数据写入
- 数据去重
- 数据导出
将数据写入 MySQL 数据库
下图所示文件是本文的数据源:
我们的设想是:编写一个小程序,扔在这个文件夹里,双击后就可以自动读取每个 txt 文档中的数据,并写入数据库。
代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 |
import pymysql import osconn = pymysql.connect(host=<span class="hljs-string">'localhost'</span>, user=<span class="hljs-string">'root'</span>, password=<span class="hljs-string">'123456'</span>, db=<span class="hljs-string">'qq'</span>, charset=<span class="hljs-string">'utf8'</span>) cur = conn.cursor()cur.<span class="hljs-built_in">execute</span>(<span class="hljs-string">"CREATE TABLE qq ( id int(5) NOT NULL auto_increment, qq varchar(20)NOT NULL, PRIMARY KEY (id));"</span>) conn.commit()<span class="hljs-built_in">path</span> = <span class="hljs-built_in">os</span>.getcwd() files = <span class="hljs-built_in">os</span>.listdir(<span class="hljs-built_in">path</span>) i = <span class="hljs-number">0</span> <span class="hljs-keyword">for</span> file <span class="hljs-keyword">in</span> files: f = <span class="hljs-built_in">open</span>(file,<span class="hljs-string">'r'</span>,encoding = <span class="hljs-string">'UTF-8'</span>) <span class="hljs-built_in">next</span>(f) <span class="hljs-keyword">for</span> line <span class="hljs-keyword">in</span> f: i += <span class="hljs-number">1</span> #<span class="hljs-built_in">print</span>(line) sql = <span class="hljs-string">"insert into qq(qq) values(%s);"</span> cur.<span class="hljs-built_in">execute</span>(sql,line) <span class="hljs-built_in">print</span>(<span class="hljs-string">"插入第"</span>, i, <span class="hljs-string">"条数据!"</span>) conn.commit() f.<span class="hljs-built_in">close</span>() cur.<span class="hljs-built_in">close</span>() conn.<span class="hljs-built_in">close</span>() |
运行效果:
重点代码解释:这段代码用到了 pymysql 和 os 两个库。
- pymysql:用来操作 MySQL 数据库;
- os:用来遍历所在文件夹下的所有文件。
现将主要代码解释如下:
1、遍历任意文件夹下所有文件名称
程序写好后,使用 pyinstaller 打包成 exe 程序,并放在要操作的文件夹下面。
通过 path = os.getcwd()命令,获取该 exe 文件所在目录。
通过 files = os.listdir(path)命令,获取 exe 文件所在目录下的所有文件名称,并存入 files 列表中。
这样我们就获得了所有的 txt 文件名称,你可以任意命名你的 txt 文件名,程序都能读出来。
2、将数据写入数据库
(1)连接数据库,并在数据库中创建新表
A. 连接到我的 qq 数据库
1 2 |
<span class="hljs-attr">conn</span> = pymysql.connect(host=<span class="hljs-string">'localhost'</span>, user=<span class="hljs-string">'root'</span>, password=<span class="hljs-string">'123456'</span>, db=<span class="hljs-string">'qq'</span>, charset=<span class="hljs-string">'utf8'</span>) |
B. 创建新表 qq
在 qq 数据库中创建新表,表名称为 qq ,包含 2 个字段:id 字段为主键、自动递增;qq 字段为字符型,用于存储数据。
1 2 |
<span class="hljs-string">cur.execute("CREATE</span> <span class="hljs-string">TABLE</span> <span class="hljs-string">qq</span> <span class="hljs-string">(</span> <span class="hljs-string">id</span> <span class="hljs-string">int(5)</span> <span class="hljs-string">NOT</span> <span class="hljs-literal">NULL</span> <span class="hljs-string">auto_increment,</span> <span class="hljs-string">qq</span> <span class="hljs-string">varchar(20)NOT</span> <span class="hljs-literal">NULL</span><span class="hljs-string">,</span> <span class="hljs-string">PRIMARY</span> <span class="hljs-string">KEY</span> <span class="hljs-string">(id))")</span> |
(2)将数据写入数据库
这里使用了两层循环:
1 2 3 4 5 6 7 8 9 10 11 |
<span class="hljs-keyword">for</span> file <span class="hljs-keyword">in</span> files: f = <span class="hljs-built_in">open</span>(file,<span class="hljs-string">'r'</span>,encoding = <span class="hljs-string">'UTF-8'</span>) <span class="hljs-built_in">next</span>(f) <span class="hljs-keyword">for</span> line <span class="hljs-keyword">in</span> f: i += <span class="hljs-number">1</span> #<span class="hljs-built_in">print</span>(line) sql = <span class="hljs-string">"insert into qq(qq) values(%s);"</span> cur.<span class="hljs-built_in">execute</span>(sql,line) <span class="hljs-built_in">print</span>(<span class="hljs-string">"插入第"</span>, i, <span class="hljs-string">"条数据!"</span>) conn.commit() f.<span class="hljs-built_in">close</span>() |
第一层循环是用来依次打开上述 17 个 txt 文件。
第二层循环是依次读取每个 txt 文件的每一行,并将改行数据插入数据库表 qq 的 qq字段。
至此就完成了数据的导入,总共32073条数据。
数据清洗
这里以去除重复值为例,简单介绍一下数据清洗。
1、创建一个新表,用来存储清洗后的数据
可以在 cmd 窗口下登陆 MySQL,打开 qq 数据库,执行下列操作:
1 2 |
<span class="hljs-keyword">CREATE</span> <span class="hljs-keyword">TABLE</span> qq_dist ( <span class="hljs-keyword">id</span> <span class="hljs-built_in">int</span>(<span class="hljs-number">5</span>) <span class="hljs-keyword">NOT</span> <span class="hljs-literal">NULL</span> auto_increment, qq <span class="hljs-built_in">varchar</span>(<span class="hljs-number">20</span>)<span class="hljs-keyword">NOT</span> <span class="hljs-literal">NULL</span>, PRIMARY <span class="hljs-keyword">KEY</span> (<span class="hljs-keyword">id</span>)); |
这样就创建了新表 qq_dist ,用来存储清洗后的数据,便于后期调用。
2、清洗数据
登陆 MySQL 后,执行下列操作:
1 2 |
<span class="hljs-keyword">insert</span> <span class="hljs-keyword">into</span> qq_dis(qq) <span class="hljs-keyword">select</span> <span class="hljs-keyword">distinct</span> qq <span class="hljs-keyword">from</span> qq; |
将从 qq 表中查找出的不重复的 qq 字段内容,插入到 qq_dist 表中的 qq 字段。
将数据按照特定格式导出
案例:将清洗后的数据的第101-200行导出到新的 txt 文本中。
代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 |
import pymysql conn = pymysql.connect(host=<span class="hljs-string">'localhost'</span>, user=<span class="hljs-string">'root'</span>, password=<span class="hljs-string">'123456'</span>, db=<span class="hljs-string">'wxid'</span>, charset=<span class="hljs-string">'utf8'</span>) <span class="hljs-built_in">print</span>(<span class="hljs-string">"写入中,请等待……"</span>) cur = conn.cursor()sql = <span class="hljs-string">"select wxid from wd_dis limit 100,100;"</span> cur.<span class="hljs-built_in">execute</span>(sql) conn.commit()alldata = cur.fetchall()f = <span class="hljs-built_in">open</span>(<span class="hljs-string">'data101-200.txt'</span>,<span class="hljs-string">'a'</span>) i = <span class="hljs-number">0</span> <span class="hljs-keyword">for</span> data <span class="hljs-keyword">in</span> alldata: i += <span class="hljs-number">1</span> f.<span class="hljs-built_in">write</span>(data[<span class="hljs-number">0</span>]) f.<span class="hljs-built_in">flush</span>() f.closecur.<span class="hljs-built_in">close</span>() conn.<span class="hljs-built_in">close</span>() <span class="hljs-built_in">print</span>(<span class="hljs-string">"写入完成,共写入{}条数据!"</span>.<span class="hljs-built_in">format</span>(i)) |
重点代码解释:
1、 limit
MySQL 中 limit m,n 函数的含义是:从第 m+1 行开始读取 n 行。
所以,本案例中读取第101-200行,就是 limit 100,100
2、flush()
flush()函数一定要加上,它可以将缓冲区的数据写入文件中。否则就会出现生成的 txt 文档为空白的错误。
https://m.toutiaocdn.com/i6835114871466492427/?app=news_article×tamp=1591433125&use_new_style=0&req_id=20200606164525010194100041147C59EF&group_id=6835114871466492427&tt_from=android_share&utm_medium=toutiao_android&utm_campaign=client_share
转载请注明:徐自远的乱七八糟小站 » 我用 Python 处理3万多条数据,只要几秒钟……