redis-py中MULTI和EXEC命令的等效功能是什么？

Question

我在 redis-cli 中测试了所有的事务命令（MULTI、EXEC、WATCH、DISCARD）。但是当我尝试使用 redis-py 时出现以下错误：

AttributeError: 'Redis' 对象没有属性 'multi'

我试过下面的代码sn-p：

import redis,time

r = redis.Redis()
try:
    r.set("transError",10)
    r.watch("transError")
    var = r.get("transError")
    var = int(var) + 1
    print "Run other client to simulate an error without transaction"
    time.sleep(4)
    r.multi()
    r.set("transError",var)
    r.execute()
    print "Value in first client",r.get("transError")

except redis.WatchError:
    print "Value Altered"

我见过使用 multi() 和 execute() 的代码示例，但它们对我不起作用。有什么帮助吗？

Answer 1

在redis-py MULTI 和EXEC 中只能通过Pipeline 对象使用。

尝试以下方法：

r = redis.Redis()
p = r.pipeline()
p.set("transError", var)
p.execute()

通过redis-cli 使用monitor 命令，您可以看到调用p.execute() 时发送的MULTI、SET、EXEC。 要省略 MULTI/EXEC 对，请使用 r.pipeline(transaction=False)。