import redis

pool = redis.ConnectionPool(db=1, decode_responses=True)

r = redis.Redis(connection_pool=pool)

# 建立管道
pipe = r.pipeline()

try:
    # 記錄操作
    # pipe.set('name', 'dahua')
    # pipe.set('age', 20)
    # 執行操作(一次性將命令發生到伺服器)
    # pipe.execute()

    # 連貫操作、鏈式操作
    pipe.set('name', 'goudan').set('age', 30
 
).execute()
except Exception as e:
    # 清空管道
    pipe.reset()


print(r.get('age'))