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.")

# On application start/restart
import redis_lock
redis_lock.reset_all(redis_client)

import redis_lock

# 設(shè)置redis連接
self.conn = redis.Redis(host='127.0.0.1', port=6379, decode_responses=True, db=3)
 
# 設(shè)置redis鎖
self.lock = redis_lock.Lock(self.conn, "redis-lock")

while True:
    # 設(shè)置redis鎖，操作redis
    if self.lock.acquire(blocking=False):
        print("Got the lock.")
        # 獲取lock，執(zhí)行業(yè)務(wù)處理
        # 獲取當(dāng)前redis鐘記錄的客戶端接收到告警的總時(shí)長(zhǎng)
        recv_time_sum_count_clients = self.conn.get(recv_time_sum_count_clients_key)
        if recv_time_sum_count_clients is None:
            recv_time_sum_count_clients = "0:0"
 
        # 獲取當(dāng)前的統(tǒng)計(jì)數(shù)據(jù)
        recv_time_sum, count_clients = recv_time_sum_count_clients.split(":")
 
        # 計(jì)算告警接收總時(shí)長(zhǎng)
        recv_time_sum = float(recv_time_sum) + recv_time
        # 計(jì)算收到預(yù)警的客戶端數(shù)量
        count_clients = int(count_clients) + 1
 
        # 寫入redis中
        recv_time_sum_count_clients = "%s:%s" % (str(recv_time_sum), str(count_clients))
        self.conn.set(recv_time_sum_count_clients_key, recv_time_sum_count_clients)
 
        print("user_id = %s, 計(jì)算平均時(shí)間成功, "
              "recv_time_sum = %s, count_clients = %s \n" %
              (self.user_id, recv_time_sum, count_clients))
 
        # 釋放lock
        self.lock.release()
 
        # 退出循環(huán)
        break
    else:
        print("Someone else has the lock.")