mysql 重试_重试MySQL/SQLAlchemy的死锁

我已经找了很长时间，找不到解决我问题的办法。我们将SQLAlchemy与MySQL一起用于我们的项目，我们多次遇到可怕的错误：1213, 'Deadlock found when trying to get lock; try restarting transaction'.

在这种情况下，我们最多尝试重新启动事务三次。

我已经开始编写一个decorator来实现这一点，但是我不知道如何在失败之前保存会话状态，然后在失败之后重试相同的事务？(因为每当引发异常时，SQLAlchemy都需要回滚)

到目前为止我的工作def retry_on_deadlock_decorator(func):

lock_messages_error = ['Deadlock found', 'Lock wait timeout exceeded']

@wraps(func)

def wrapper(*args, **kwargs):

attempt_count = 0

while attempt_count < settings.MAXIMUM_RETRY_ON_DEADLOCK:

try:

return func(*args, **kwargs)

except OperationalError as e:

if any(msg in e.message for msg in lock_messages_error)

and attempt_count <= settings.MAXIMUM_RETRY_ON_DEADLOCK:

logger.error('Deadlock detected. Trying sql transaction once more. Attempts count: %s'

% (attempt_count + 1))

else:

raise

attempt_count += 1

return wrapper