我有一个奇怪的问题。我有一个简单的 py3 应用程序,它使用 sqlalchemy。
但是几个小时后,出现错误:
(sqlalchemy.exc.InvalidRequestError) 在无效事务回滚之前无法重新连接
我的初始化部分:
self.db_engine = create_engine(self.db_config, pool_pre_ping=True) # echo=True if needed to see background SQL
Session = sessionmaker(bind=self.db_engine)
self.db_session = Session()
Run Code Online (Sandbox Code Playgroud)
查询(这是唯一发生的查询):
while True:
device_id = self.db_session.query(Device).filter(Device.owned_by == msg['user_id']).first()
sleep(20)
Run Code Online (Sandbox Code Playgroud)
整个脚本处于无限循环中,单线程(SQS 读出)。有人解决这个问题吗?