数据帧 to_sql 不等待执行?
Data Frame to_sql without waiting for execution?
我在这里到处找,我找不到一种方法来执行简单的单行插入而不等待响应,继续执行下一行:
engine = sqlalchemy.create_engine('postgresql+psycopg2://' + username + ':' + password + '@/' + database + "?host=" + path)
df.to_sql('queries', engine, if_exists='append', index=False)
这在服务器上运行以将一些分析保存到 Postgresql,我不想等待响应,我也不在乎它是否偶尔失败。
这对我来说非常重要,之后继续执行,不要花时间在这上面。
如何操作?
来自文档 df.to_sql() 不支持您想要的内容。但是您可以采取一些解决方法:
- 创建一个使用线程将此 df 插入您的数据库的函数。检查 this answer.
- 您可以使用异步调用和 sqlalchemy,但您需要将此数据框映射到对象或 sqlalchemy 可以使用的对象。
我在这里到处找,我找不到一种方法来执行简单的单行插入而不等待响应,继续执行下一行:
engine = sqlalchemy.create_engine('postgresql+psycopg2://' + username + ':' + password + '@/' + database + "?host=" + path)
df.to_sql('queries', engine, if_exists='append', index=False)
这在服务器上运行以将一些分析保存到 Postgresql,我不想等待响应,我也不在乎它是否偶尔失败。
这对我来说非常重要,之后继续执行,不要花时间在这上面。
如何操作?
来自文档 df.to_sql() 不支持您想要的内容。但是您可以采取一些解决方法:
- 创建一个使用线程将此 df 插入您的数据库的函数。检查 this answer.
- 您可以使用异步调用和 sqlalchemy,但您需要将此数据框映射到对象或 sqlalchemy 可以使用的对象。