Python 错误 : execute cannot be used while an asynchronous query is underway

Question

如何防止错误“ProgrammingError: execute cannot be used while an asynchronous query is underly”？从文档中可以看出，如果我使用像 gevent 这样的协程支持，我应该使用 psycopg2.extras.wait_select，但我在使用它时仍然遇到该错误。我已经隔离了我在下面的代码片段中遇到的错误。

con = psycopg2.connect(database=DATABASE_NAME, user=DATABASE_USERNAME)

def execute_query(cur, query, params):
    psycopg2.extras.wait_select(con)
    cur.execute(query, params)
    psycopg2.extras.wait_select(con)
    rows = cur.fetchall()
    print rows[0]

cur = con.cursor()
query = "SELECT * FROM mytable"
gevent.joinall([
     gevent.spawn(execute_query, cur, query, None),
     gevent.spawn(execute_query, cur, query, None),
     gevent.spawn(execute_query, cur, query, None),
     gevent.spawn(execute_query, cur, query, None)
])

Answer 1

您正在尝试在一个连接上同时进行多个事务。 psycopg 文档说这不是线程安全的，会导致错误。参见 Asynchronous support and Support for coroutine libraries

一种可能的解决方案是每个协程使用一个数据库连接，每个连接有一个游标(在本例中为 4 个不同的连接和游标)。