我正在尝试通过使用 fast_executemany 来加速 to_sql()。但我得到一个错误,
类型错误:使用配置 PGDialect_psycopg2/QueuePool/Engine 将无效参数“fast_executemany”发送到 create_engine()。请检查关键字参数是否适合这种组件组合。
我一直在参考上一个问题,Speeding up pandas.DataFrame.to_sql with fast_executemany of pyODBC。
database_url = 'postgresql://{user}:{password}@{host}:5432/{database_name}'.format(
user=user,
host=host,
password=password,
database_name=database_name,
)
engine = create_engine(database_url, echo=False, fast_executemany=True)
df.to_sql('parquet', con=engine,if_exists='replace')
如果我删除 fast_executemany 参数,此代码将执行,但需要很长时间。我正在使用 Python 3.7。