DB: sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError) (2013, 'Lost connection to MySQL server during query')

问题描述 投票:0回答:0

尝试

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)
...

有人知道解决这个问题的方法吗?

我尝试扩大池超时但没有运气。

mysql sqlalchemy database-connection
© www.soinside.com 2019 - 2024. All rights reserved.