数据帧 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() 不支持您想要的内容。但是您可以采取一些解决方法:

  1. 创建一个使用线程将此 df 插入您的数据库的函数。检查 this answer.
  2. 您可以使用异步调用和 sqlalchemy,但您需要将此数据框映射到对象或 sqlalchemy 可以使用的对象。