python-redis-lock
多個redis客戶端訪問同一個redis服務端,控制並發。
github:https://pypi.org/project/python-redis-lock/
在使用這個庫之前,需要安裝如下:
pip install python-redis-lock
使用鎖的示例:
lock = redis_lock.Lock(conn, "name-of-the-lock") if lock.acquire(blocking=False): print("Got the lock.") lock.release() else: print("Someone else has the lock.")
上面是單獨設置鎖的方式,還可以單獨設置所有redis的操作加入鎖。
# On application start/restart import redis_lock redis_lock.reset_all(redis_client)
快速使用
1. 首先導入redis_lock
import redis_lock
2.將redis連接的客戶端傳入lock中,並設置lock的名稱
# 設置redis連接 conn = redis.Redis(host='127.0.0.1', port=6379, decode_responses=True, db=0) # 設置redis鎖 lock = redis_lock.Lock(conn, "redis-lock")
3.業務操作
if lock.acquire(blocking=False): print("Got the lock.") # 獲取lock,執行業務處理 # 釋放lock self.lock.release() else: print("Someone else has the lock.")
簡單方式:
with redis_lock.Lock(conn, "name-of-the-lock"): print("Got the lock. Doing some work ...") time.sleep(5)