红移中的手柄锁

Question

我有一个 python 脚本，它在 Redshift 中执行多个 sql 脚本（一个接一个）。这些sql脚本中的一些表可以被多次查询。例如。表 t1 可以在一个脚本中选择，并且可以在另一个脚本中删除/重新创建。这整个过程在一个事务中运行。现在，有时，我收到检测到死锁的错误，整个事务被回滚。如果表出现死锁，我想等表释放后再重试sql执行。对于其他类型的错误，我想回滚事务。从文档中，看起来表锁直到事务结束才被释放。我想实现所有或没有数据更改（通过使用事务来完成），但也想处理死锁。关于如何实现这一点的任何建议？

Answer 1

我会在一个带有重试循环的事务中执行您所指的所有 SQL。下面是我用来处理并发问题和重试的逻辑（为简洁起见，伪代码）。我没有让系统无限期地等待锁被释放。相反，我通过随着时间的推移重试来在应用程序中处理它。

begin transaction
while not successful and count < 5
    try 
        execute sql
        commit
    except
        if error code is '40P01' or '55P03'
            # Deadlock or lock not available
            sleep a random time (200 ms to 1 sec) * number of retries
        else if error code is '40001' or '25P02'
            # "In failed sql transaction" or serialized transaction failure
            rollback
            sleep a random time (200 ms to 1 sec) * number of retries
            begin transaction
        else if error message is 'There is no active transaction'
            sleep a random time (200 ms to 1 sec) * number of retries
            begin transaction
    increment count

关键组件捕获每个type of error，知道哪些情况需要回滚，并拥有exponential backoff for retries。