Come posso unire le connessioni usando psycopg e gevent?

Question

Lo stato di psycopg dichiara: "Le connessioni Psycopg non sono thread verdi sicuri e non possono essere utilizzate contemporaneamente da thread verdi diversi. Provare a eseguire più di un comando alla volta utilizzando un cursore per thread causerà un errore (o un deadlock sulle versioni precedenti alla 2.4.2). Pertanto, si consiglia ai programmatori di evitare la condivisione delle connessioni tra le coroutine o di utilizzare un blocco di tipo libreria per sincronizzare le connessioni condivise, ad esempio per il pooling. "

Non riesco a trovare un'implementazione di pool che sia sicuro per il thread verde: ce ne sono alcuni là fuori?

Answer 1

presumo si sa gevent-psycopg2 modulo, il che rende psycopg greenlet-friendly.

in cerca di soluzione il pool di connessioni Ho provato 2 soluzioni:

• SQLALchemy - sembra funzionare correttamente con le discussioni scimmia-patched e gevent-psycopg2. La classe QueuePool utilizza internamente il modulo threading per il blocco, pertanto è necessario applicare patch di scimmia, anche se gevent-psycopg2 fa il numero verde psycopg2.

• c'è un psycopg2connection pooling example in gevent esempi

ho provato entrambe le soluzioni, ma non a carico di produzione - quindi non posso dire sulla loro robustezza ancora.

Answer 2

Ecco una bella piscina (non solo esempio, ma usato in produzione): psycopg2_pool.py

Answer 3

Se chiami gevent.monkey.patch_thread() dovresti essere in grado di utilizzare psycopg2.pool.ThreadedConnectionPool.

• docs: http://initd.org/psycopg/docs/pool.html#psycopg2.pool.ThreadedConnectionPool
• fonte: https://github.com/dvarrazzo/psycopg/blob/2_4_5/lib/pool.py#L173