Python从数据库读取大量数据批量写入文件的方法

水深无声 2023-10-07 13:48 10阅读 0赞

今天小编就为大家分享一篇Python从数据库读取大量数据批量写入文件的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

使用机器学习训练数据时，如果数据量较大可能我们不能够一次性将数据加载进内存，这时我们需要将数据进行预处理，分批次加载进内存。

下面是代码作用是将数据从数据库读取出来分批次写入txt文本文件，方便我们做数据的预处理和训练机器学习模型。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 </td> 
 <td> <code>#%%</code> <code>import</code> <code>pymssql as MySQLdb </code><code>#这里是python3 如果你是python2.x的话，import MySQLdb</code> <code>#数据库连接属性</code> <code>hst </code><code>=</code> <code>'188.10.34.18'</code> <code>usr </code><code>=</code> <code>'sa'</code> <code>passwd </code><code>=</code> <code>'p@ssw0rd'</code> <code>db </code><code>=</code> <code>'HistoryTrace'</code> <code>&nbsp;</code>&nbsp; <code>#总共多少数据</code> <code>allData </code><code>=</code> <code>1674333</code> <code>#每个批次多少条数据</code> <code>dataOfEach </code><code>=</code> <code>20000</code> <code>#批次</code> <code>batch </code><code>=</code> <code>ceil(allData</code><code>/</code><code>dataOfEach)</code> <code>&nbsp;</code>&nbsp; <code>#文件名</code> <code>global</code> <code>IDctrl </code> <code>IDctrl </code><code>=</code> <code>1</code> <code>filename </code><code>=</code> <code>str</code><code>(IDctrl)</code><code>+</code><code>'.txt'</code> <code>&nbsp;</code>&nbsp; <code>#连接数据库</code> <code>conn </code><code>=</code> <code>MySQLdb.connect(host</code><code>=</code><code>hst,user</code><code>=</code><code>usr,password</code><code>=</code><code>passwd,database</code><code>=</code><code>db)</code> <code>cur</code><code>=</code><code>conn.cursor()</code> <code>&nbsp;</code>&nbsp; <code>while</code> <code>IDctrl&lt;batch:</code> <code>&nbsp;</code><code>#读取数据库</code> <code>&nbsp;</code><code>sql </code><code>=</code> <code>'SELECT Longitude,Latitude,Altitude,VelComOfLong,VelComOfLati,Aircraft,Section,TimeMinus\</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>FROM dealed1 where </code><code>ID</code><code>&gt;</code><code>=</code><code>' + str(IDctrl) + '</code> <code>and</code> <code>ID</code> <code>&lt;' </code><code>+</code> <code>str</code><code>(IDctrl </code><code>+</code> <code>dataOfEach) </code> <code>&nbsp;</code><code>cur.execute(sql)</code> <code>&nbsp;</code><code>rows</code><code>=</code><code>cur.fetchall()</code> <code>&nbsp;</code><code>#写文件</code> <code>&nbsp;</code><code>f </code><code>=</code> <code>open</code><code>(filename,</code><code>'w'</code><code>)</code> <code>&nbsp;</code><code>f.writelines(</code><code>str</code><code>(rows))</code> <code>&nbsp;</code><code>#文件名加1</code> <code>&nbsp;</code><code>IDctrl</code><code>+</code><code>=</code><code>1</code> <code>&nbsp;</code><code>filename </code><code>=</code> <code>str</code><code>(IDctrl)</code><code>+</code><code>'.txt'</code> <code>&nbsp;</code>&nbsp; <code>#关闭数据库连接</code> <code>f.close()</code> <code>conn.close()</code> </td> 
 </tr> 
 </tbody> 
</table>

以上这篇Python从数据库读取大量数据批量写入文件的方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。

来源:[https://www.jb51.net/article/152445.htm][https_www.jb51.net_article_152445.htm]

[https_www.jb51.net_article_152445.htm]: https://www.jb51.net/article/152445.htm