分布式系统设计

// 分布式锁实现示例 (Redis)
def acquire_lock(redis_client, lock_key, lock_value, expire_time=30):
    """
    获取分布式锁
    """
    result = redis_client.set(
        lock_key,
        lock_value,
        nx=True,  # 仅当 key 不存在时设置
        ex=expire_time  # 设置过期时间
    )
    return result is True

def release_lock(redis_client, lock_key, lock_value):
    """
    释放分布式锁 (Lua 脚本保证原子性)
    """
    lua_script = """
    if redis.call("get", KEYS[1]) == ARGV[1] then
        return redis.call("del", KEYS[1])
    else
        return 0
    end
    """
    return redis_client.eval(lua_script, 1, lock_key, lock_value)