redlock

import redis from redlock import Redlock import os # Configure Redis instances. For production, use multiple instances # and ensure they are properly configured for high availability. # Here, we default to localhost for a runnable example. redis_host = os.environ.get('REDIS_HOST', 'localhost') redis_port = int(os.environ.get('REDIS_PORT', 6379)) redis_masters = [ {"host": redis_host, "port": redis_port, "db": 0} # For true distributed locking, add more Redis instances: # {"host": "192.168.1.30", "port": 6379, "db": 0}, # {"host": "192.168.1.31", "port": 6379, "db": 0} ] # Initialize Redlock with Redis instances dlm = Redlock(redis_masters=redis_masters) resource_name = "my_critical_resource" lock_ttl = 5000 # Lock validity time in milliseconds (5 seconds) print(f"Attempting to acquire lock for resource: {resource_name}") lock_info = dlm.lock(resource_name, lock_ttl) if lock_info: print(f"Successfully acquired lock: {lock_info}") try: # --- Critical section begins --- print("Performing critical operation...") # Simulate work import time time.sleep(2) # Keep operation less than lock_ttl # --- Critical section ends --- finally: print("Releasing lock...") dlm.unlock(lock_info) print("Lock released.") else: print(f"Failed to acquire lock for resource: {resource_name}. It might be held by another process.")