redislock

Async библиотека для distributed locks и concurrency control через Redis.

Возможности

• Distributed Locks: Блокировки через Redis для координации между процессами/серверами
• Concurrency Limiting: Ограничение количества одновременных операций
• Registry Pattern: Удобное управление через register() и get()
• Async/Await: Полная поддержка asyncio
• Context Managers: Автоматическое освобождение ресурсов

Установка

poetry add redislock --path /Users/aleks/Libraryies/redislock

Использование

Инициализация

import red_mng
from redislock import register, get

# Регистрация
redis = red_mng.get("default")
register("default", redis)

# Получение
locks = get("default")

Distributed Locks

# Защита критической секции
async with locks.acquire("orderbook:BTCUSDT:binance"):
    # Только один процесс выполнит этот код
    await update_orderbook()

# С кастомными таймаутами
async with locks.acquire("resource", timeout=10, blocking_timeout=20):
    await critical_operation()

Concurrency Limiting

# Ограничение параллельных API запросов
async with locks.limiter("api_calls", limit=50):
    await make_api_call()

# Ограничение обновлений orderbook
async with locks.limiter("orderbook_updates", limit=100):
    await update_orderbook()

Интеграция с проектом

from redislock import get
from config_fastapi import Config
import red_mng as redis_manager

class BaseRedisControl:
    def __init__(self):
        config = Config(section="redis")
        self.redis = redis_manager.get(config.get("alias"))
        self.locks = get(config.get("alias"))

Архитектура

• DistributedLock: Использует redis.asyncio.lock.Lock
• ConcurrencyLimiter: Использует asyncio.Semaphore
• LockManager: Unified interface для обоих
• Registry pattern: Singleton per alias

Преимущества

✅ Работает в распределенной среде (несколько серверов) ✅ Автоматическое освобождение блокировок ✅ Настраиваемые таймауты ✅ Логирование через logging ✅ Type hints ✅ Минимальные зависимости