$ pip install redlock-py

from contextlib import contextmanager
from redlock import Redlock

@contextmanager
def worker_lock_manager(key, ttl, **kwargs):
    """
    分布式锁
    :param key: 分布式锁ID
    :param ttl: 分布式锁生存时间
    :param kwargs: 可选参数字典
    :return: None
    """
    redis_servers = [{
        ‘host‘: ‘127.0.0.1‘,
        ‘port‘: 6379,
        ‘db‘: 0,
        ‘password‘: ‘pwd‘
    }]

    rlk= Redlock(redis_servers)

    # 获取锁
    lock = rlk.lock(key, ttl)
 
    yield lock

    # 释放锁
    rlk.unlock(lock)

with worker_lock_manager(‘unique_key‘, 1000) as w_lock:
        if w_lock is False:
               return
        do_something()