南沙区做网站,成都房地产信息网官网,长沙门户网站,义乌产品设计公司目的在数据分析时#xff0c;我们有中间结果#xff0c;或者最终的结果#xff0c;需要保存到数据库中#xff1b;或者我们有一个中间的结果#xff0c;如果放到数据库中通过sql操作会更加的直观#xff0c;处理后再将结果读取到DataFrame中。这两个场景#xff0c;就需…目的在数据分析时我们有中间结果或者最终的结果需要保存到数据库中或者我们有一个中间的结果如果放到数据库中通过sql操作会更加的直观处理后再将结果读取到DataFrame中。这两个场景就需要用到DataFrame的to_sql操作。具体的操作连接数据库代码import pandas as pdfrom sqlalchemy import create_engine# defaultengine create_engine(mysqlpymysql://ledao:ledao123localhost/pandas_learn)original_data pd.read_sql_table(cellfee, engine)original_data结果如下所示。对数据进行汇总每个小区的电费进行求和放到Series中然后将所有小区的总电费放到DataFrame中最后将DataFrame保存到数据库中代码如下所示。all_cells []for k, v in original_data.groupby(by[cityid, cellid]):onecell pd.Series(data[k[0], k[1], v[fee].sum()], index[cityid, cellid, fee_sum])all_cells.append(onecell)all_cells pd.DataFrame(all_cells)all_cells.to_sql(namecells_fee, conengine, chunksize1000, if_existsreplace, indexNone)对于DataFrame的to_sql函数需要注意的参数在代码中已经写出来其中比较重要的是chunksize、if_exists和index。chunksize可以设置一次入库的大小if_exists设置如果数据库中存在同名表怎么办‘replace表示将表原来数据删除放入当前数据‘append表示追加‘fail则表示将抛出异常结束操作默认是‘failindex接受boolean值表示是否将DataFrame的index也作为表的列存储。最终存表的结果如下图所示。以上就是本文的全部内容希望对大家的学习有所帮助也希望大家多多支持脚本之家。
