연결 개체를 호출하지 - SQLAlchemy의/pymysql 내가 SQLAlchemy의와 pymysql로 ​​연결 풀링을 구현하기 위해 노력하고

Question

:

import pymysql 
import sqlalchemy.pool as pool 

# Lifted from the pymysql docs: https://github.com/PyMySQL/PyMySQL/blob/master/example.py 
cnx = pymysql.connect(host='localhost',user='xxxx',password='xxxx',db='mydatabase') 


# Lifted straight from the SQLAlchemy docs http://docs.sqlalchemy.org/en/latest/core/pooling.html: 
cnxPool = pool.QueuePool(cnx, max_overflow=10, pool_size=5) 
conn = cnxPool.connect() 
cursor = conn.cursor() 
cursor.execute("select * from PUBLIC_URLS") 
cursor.close() 

단순히 상당히 긴 스택 추적의 맨 아래에 다음과 같은 오류가 발생합니다 :

File "/usr/local/lib/python2.7/dist-packages/SQLAlchemy-1.1.3-py2.7-linux-x86_64.egg/sqlalchemy/pool.py", line 279, in <lambda> 
    return lambda crec: creator() 
TypeError: 'Connection' object is not callable 

무엇이 잘못 되었습니까?

감사

Answer 1

QueuePool의 첫 번째 인수는 새로운 연결을 반환하는 함수이어야합니다. 풀이 새로운 연결을 필요로 할 때마다 호출됩니다.

연결이 아닌 함수를 전달 중입니다. QueuePool이 전화를 걸려고하면 TypeError: 'Connection' object is not callable 오류가 발생합니다.

시도 대신이 : 물론

... 
def getconn(): 
    return pymysql.connect(host='localhost',user='xxxx',password='xxxx',db='mydatabase') 

cnxPool = pool.QueuePool(getconn, max_overflow=10, pool_size=5) 
...