1. 程式人生 > >Python 使用pipeline 一次性操作 Redis

Python 使用pipeline 一次性操作 Redis

1、普通操作例項

import redis

# 連線池方式 db表示選擇資料庫
pool = redis.ConnectionPool(host='111.231.135.184',port=6379,db=0)
r = redis.Redis(connection_pool=pool)
r.set('name', 'world')
print(r.get('name'))

2、pipeline操作例項

import redis
import time

# 連線池方式 db表示選擇資料庫
pool = redis.ConnectionPool(host='111.231.135.184',port=6379,db=0)
r = redis.Redis(connection_pool=pool)

# 緩衝多條命令,然後一次性執行
pipe = r.pipeline()

# 正常情況下,50秒後會執行這些命令,在50秒之前去 資料庫檢視是沒有值的
pipe.set('name', 'world')
time.sleep(50)
pipe.get('name')
pipe.execute()