import redis
# 连接到 Redis 数据库
r = redis.Redis(host='localhost', port=6379, db=0)
# 创建一个 Pipeline 对象
pipe = r.pipeline()
# 在 Pipeline 中依次执行多个命令
pipe.set('key1', 'value1')
pipe.set('key2', 'value2')
pipe.set('key3', 'value3')
# 执行 Pipeline 中的所有命令
pipe.execute()
# 从 Redis 中获取设置的值,仅用于演示
value1 = r.get('key1')
value2 = r.get('key2')
value3 = r.get('key3')
# 打印获取的值,仅用于演示
print(f"key1: {value1}")
print(f"key2: {value2}")
print(f"key3: {value3}")
在上面的示例代码中,我们首先创建了一个 Redis 连接对象 r,然后创建了一个 Pipeline 对象 pipe。接着,在 Pipeline 中依次执行了三个设置命令,分别设置了三个键值对。最后,通过 pipe.execute() 执行 Pipeline 中的所有命令。
请注意,Pipeline 中的命令并不会立即执行,而是在调用 execute() 方法时一次性发送到 Redis 服务器执行,这有助于减少网络延迟。