Errore Python: esecuzione non può essere utilizzata mentre è in corso una query asincrona

Question

Come si impedisce l'errore "ProgrammingError: execute cannot be used while an asynchronous query is underway"? Dai documenti dice che dovrei usare psycopg2.extras.wait_select se sto usando un supporto di coroutine come gevent., Ma sto ancora ricevendo quell'errore quando lo sto usando. Ho isolato l'errore che sto ricevendo nello snippet qui sotto.

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

Si sta tentando di eseguire più di una transazione contemporaneamente su una singola connessione. La documentazione di psycopg dice che questo non è thread-safe e porterà a un errore. Vedi sotto Asynchronous support and Support for coroutine libraries

Una possibile soluzione è utilizzare una connessione al database, ciascuna con un cursore, per coroutine (4 connessioni distinte e cursori in questo caso).