尝试
with engine.begin() as conn
后出现“连接断开”错误。这是我的代码:
...
connection_pool = get_connection_pool(_db)
conn = connection_pool.getconn()
server = str(_db.credentials.host) + ":" + str(_db.credentials.port)
database = _db.credentials.database
user = _db.credentials.user
password = _db.credentials.password
# connection_string = "DRIVER={mysql+pymysql};" + "SERVER=" + server + ";DATABASE=" + database +";UID=" + user + ";PWD=" + password
# connection_url = URL.create('mysql+pymysql', query={"odbc_connect": connection_string})
connection_url = "mysql+pymysql://" + user + ":" + password + "@" + server + "/" + database
try:
q = query.as_string((conn))
engine = create_engine(connection_url)
_logger.info(q)
with engine.begin() as conn:
return pd.read_sql_query(q, conn)
except psycopg2.DatabaseError as ex:
_logger.info(ex)
raise ex
finally:
connection_pool.putconn(conn)
...
有人知道解决这个问题的方法吗?
我尝试扩大池超时但没有运气。