2

我插入了很多行，似乎 postgress 跟不上。我google了一下，建议你可以关闭自动提交。我不需要立即提交这些值。如果出现问题，我可以再次获取这些数据。

现在，当我搜索关闭自动提交时，我没有找到我正在寻找的东西。我尝试在 dbpool 构造函数中提供 autocommit=False ：

dbpool = adbapi.ConnectionPool('psycopg2', user="xxx", password="xxx", database="postgres", host="localhost", autocommit=False)

2013-01-27 18:24:42,254-collector.EventLogItemController-警告-[失败实例：回溯：：无效连接选项“自动提交”

4

3 回答 3

1

psycopg2 不声称支持以下autocommit关键字参数connect：

connect(dsn=None, database=None, user=None, password=None, host=None, port=None, connection_factory=None, async=False, **kwargs)
    Create a new database connection.

    The connection parameters can be specified either as a string:

        conn = psycopg2.connect("dbname=test user=postgres password=secret")

    or using a set of keyword arguments:

        conn = psycopg2.connect(database="test", user="postgres", password="secret")

    The basic connection parameters are:

    - *dbname*: the database name (only in dsn string)
    - *database*: the database name (only as keyword argument)
    - *user*: user name used to authenticate
    - *password*: password used to authenticate
    - *host*: database host address (defaults to UNIX socket if not provided)
    - *port*: connection port number (defaults to 5432 if not provided)

    Using the *connection_factory* parameter a different class or connections
    factory can be specified. It should be a callable object taking a dsn
    argument.

    Using *async*=True an asynchronous connection will be created.

    Any other keyword parameter will be passed to the underlying client
    library: the list of supported parameter depends on the library version.

当前的 postgresql 文档也没有讨论任何“自动提交”参数：

http://www.postgresql.org/docs/current/static/libpq-connect.html#LIBPQ-CONNSTRING

所以也许问题是这不是为 psycopg2 连接禁用自动提交的正确方法。除此之外，您不会发现关闭自动提交实际上对您有帮助。 adbapi.ConnectionPool将为您开始并提交显式事务，回避任何autocommit可能给您的行为模式。

于 2013-01-27T20:43:39.323 回答
0

adbapi 的问题在于：1）它缺少特定于某些数据库后端的功能 2）它的假异步 api。在幕后它使用线程池并调用阻塞方法。

对于 postgres，我建议使用 txpostgres 库（来源在这里：https ://github.com/wulczer/txpostgres ）。它使用 psycopg2 的异步 api，它允许您指定连接字符串。你可以在这里找到一个例子：http: //txpostgres.readthedocs.org/en/latest/usage.html#customising-the-connection-and-cursor-factories

于 2013-01-27T19:33:53.977 回答
0

使用cp_openfuntwisted.enterprise.adbapi.ConnectionPool构造函数的选项

以连接作为参数调用此函数。

在 psycopg2 的情况下，您可以将该连接的自动提交属性设置为True或False按此处所述

于 2018-06-20T09:16:43.983 回答