python-redis-lock
多個(gè)redis客戶端訪問(wèn)同一個(gè)redis服務(wù)端,控制并發(fā)。
github:https://pypi.org/project/python-redis-lock/
在使用這個(gè)庫(kù)之前,需要安裝如下:
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.")
上面是單獨(dú)設(shè)置鎖的方式,還可以單獨(dú)設(shè)置所有redis的操作加入鎖。
# On application start/restart
import redis_lock
redis_lock.reset_all(redis_client)
快速使用
1. 首先導(dǎo)入redis_lock
import redis_lock
2.將redis連接的客戶端傳入lock中,并設(shè)置lock的名稱
# 設(shè)置redis連接
conn = redis.Redis(host='127.0.0.1', port=6379, decode_responses=True, db=0)
# 設(shè)置redis鎖
lock = redis_lock.Lock(conn, "redis-lock")
3.業(yè)務(wù)操作
if lock.acquire(blocking=False):
print("Got the lock.")
# 獲取lock,執(zhí)行業(yè)務(wù)處理
# 釋放lock
self.lock.release()
else:
print("Someone else has the lock.")
簡(jiǎn)單方式:
with redis_lock.Lock(conn, "name-of-the-lock"):
print("Got the lock. Doing some work ...")
time.sleep(5)
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
您可能感興趣的文章:- python爬蟲(chóng)分布式獲取數(shù)據(jù)的實(shí)例方法
- python分布式爬蟲(chóng)中消息隊(duì)列知識(shí)點(diǎn)詳解
- Python通過(guò)zookeeper實(shí)現(xiàn)分布式服務(wù)代碼解析
- Python 分布式緩存之Reids數(shù)據(jù)類型操作詳解
- Python3與fastdfs分布式文件系統(tǒng)如何實(shí)現(xiàn)交互
- python如何使用Redis構(gòu)建分布式鎖
- python分布式計(jì)算dispy的使用詳解
- 基于python分布式爬蟲(chóng)并解決假死的問(wèn)題