使用 map_partitions 和 pd.df.to_sql 从 dask

Question

Dask 没有像 Pandas 那样的 df.to_sql() ，所以我试图复制该功能并使用该map_partitions方法创建一个 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 数据框对象，但是当我查看我的 psql 服务器时，没有新表......这里出了什么问题？