最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

pandas實(shí)現(xiàn)to_sql將DataFrame保存到數(shù)據(jù)庫中

 更新時(shí)間:2019年07月03日 09:17:25   作者:ledao  
這篇文章主要介紹了pandas實(shí)現(xiàn)to_sql將DataFrame保存到數(shù)據(jù)庫中,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

目的

在數(shù)據(jù)分析時(shí),我們有中間結(jié)果,或者最終的結(jié)果,需要保存到數(shù)據(jù)庫中;或者我們有一個(gè)中間的結(jié)果,如果放到數(shù)據(jù)庫中通過sql操作會更加的直觀,處理后再將結(jié)果讀取到DataFrame中。這兩個(gè)場景,就需要用到DataFrame的to_sql操作。

具體的操作

連接數(shù)據(jù)庫代碼

import pandas as pd
from sqlalchemy import create_engine
# default
engine = create_engine('mysql+pymysql://ledao:ledao123@localhost/pandas_learn')
original_data = pd.read_sql_table('cellfee', engine)
original_data

結(jié)果如下所示。

對數(shù)據(jù)進(jìn)行匯總,每個(gè)小區(qū)的電費(fèi)進(jìn)行求和放到Series中,然后將所有小區(qū)的總電費(fèi)放到DataFrame中,最后將DataFrame保存到數(shù)據(jù)庫中,代碼如下所示。

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(name='cells_fee', con=engine, chunksize=1000, if_exists='replace', index=None)

對于DataFrame的to_sql函數(shù),需要注意的參數(shù)在代碼中已經(jīng)寫出來,其中比較重要的是chunksize、if_exists和index。
chunksize可以設(shè)置一次入庫的大??;if_exists設(shè)置如果數(shù)據(jù)庫中存在同名表怎么辦,‘replace'表示將表原來數(shù)據(jù)刪除放入當(dāng)前數(shù)據(jù);‘a(chǎn)ppend'表示追加;‘fail'則表示將拋出異常,結(jié)束操作,默認(rèn)是‘fail';index=接受boolean值,表示是否將DataFrame的index也作為表的列存儲。

最終存表的結(jié)果如下圖所示。

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

最新評論

泰和县| 赤壁市| 尼勒克县| 习水县| 衡南县| 峨眉山市| 南平市| 盐源县| 定日县| 双鸭山市| 汉中市| 视频| 凤山市| 佛教| 渝北区| 天柱县| 自贡市| 瓦房店市| 平山县| 镇雄县| 唐河县| 尚义县| 岑溪市| 孝义市| 舞阳县| 阿图什市| 罗源县| 贺兰县| 苍梧县| 留坝县| 垣曲县| 崇仁县| 陕西省| 长岛县| 海晏县| 霸州市| 太谷县| 盖州市| 临江市| 巴彦淖尔市| 永州市|