Python处理Redis事务的实例讲解

Redis事务

在Redis中，一个基本事务包括MULTI和EXEC，意思是提供给客户端执行多个命令A,B,C,…的功能，其他客户端不能打断。这个和关系型数据库的可以部分执行，然后回滚或递交的事务不同。

在Redis中，每个作为一个基本的MULTI/EXEC事务的一部分传递的命令，都将一个执行完执行下一个。在它们都执行完毕后，其客户端才可以执行自己的命令。

当看到MULTI，Redis将会从相同的连接组建命令队列，直到它看到一个EXEC，才会不中断的执行整个命令队列。

Python处理Redis事务

在语义上，Python类库处理事务使用一个叫pipeline的方法。在连接对象上调用pipeline()方法将会创建一个事务，正确的话将会自动使用MULTI和EXEC包装一个命令队列。

Python Redis客户端也会存储命令，直到我们真正需要发送的时候才发送。这会减少Redis和客户端的交互次数，提高性能。

简单示例

import redis


def demo():
    try:
        redis_client = redis.StrictRedis.from_url('redis://10.38.164.243:6386')
        pipe = redis_client.pipeline()

        key = 'demo'
        pipe.set(key, 'demo_test_val')
        pipe.execute()

        pipe.get(key)
        val = pipe.execute()
        print(val)  # 输出: ['demo_test_val']
    except Exception as e:
        print(e)