Dask 沒有像 Pandas 那樣的 df.to_sql() ,所以我試圖復(fù)制該功能并使用該map_partitions方法創(chuàng)建一個(gè) sql 表。這是我的代碼:import dask.dataframe as ddimport pandas as pdimport sqlalchemy_utils as sqla_utilsdb_url = 'my_db_url_connection'conn = sqla.create_engine(db_url)ddf = dd.read_csv('data/prod.csv')meta=dict(ddf.dtypes)ddf.map_partitions(lambda df: df.to_sql('table_name', db_url, if_exists='append',index=True), ddf, meta=meta)這將返回我的 dask 數(shù)據(jù)框?qū)ο?,但是?dāng)我查看我的 psql 服務(wù)器時(shí),沒有新表......這里出了什么問題?
添加回答
舉報(bào)
0/150
提交
取消