redlock-py

import os from redlock import Redlock import redis # Configure Redis connection(s) # For a true Redlock setup, use multiple independent Redis instances. # For quickstart, a single local instance is shown. REDIS_HOST = os.environ.get('REDIS_HOST', 'localhost') REDIS_PORT = int(os.environ.get('REDIS_PORT', 6379)) REDIS_DB = int(os.environ.get('REDIS_DB', 0)) redis_nodes = [ {"host": REDIS_HOST, "port": REDIS_PORT, "db": REDIS_DB} # For production, add more independent Redis nodes, e.g.: # {"host": "redis2.example.com", "port": 6379, "db": 0}, # {"host": "redis3.example.com", "port": 6379, "db": 0}, ] # Initialize the Redlock manager dlm = Redlock(redis_nodes) resource_name = "my_critical_resource" lock_validity_time_ms = 5000 # Lock will be valid for 5 seconds try: # Acquire the lock using a context manager (recommended) print(f"Attempting to acquire lock for '{resource_name}'...") with dlm.lock(resource_name, lock_validity_time_ms) as my_lock: if my_lock: print(f"Lock '{resource_name}' acquired! (Validity: {my_lock.validity}ms)") # Your critical section code goes here print("Executing critical section...") # Simulate work import time time.sleep(2) print("Critical section complete.") else: print(f"Could not acquire lock for '{resource_name}'. Another process may hold it.") except redis.exceptions.ConnectionError as e: print(f"Error connecting to Redis: {e}. Make sure Redis is running.") except Exception as e: print(f"An unexpected error occurred: {e}") print("Finished redlock-py quickstart example.")