redlock_distributed_lock_context_manager_quickstart.py

1from redlock import Redlock
2
3# Create a list of Redis nodes to connect to
4servers = [
5    {"host": "localhost", "port": 6379, "db": 0},
6]
7
8# Initialize the Redlock distributor
9dlm = Redlock(servers)
10
11# Use the lock as a context manager
12# The resource name is "my_resource_name" and the TTL is 1000ms (1 second)
13with dlm.lock("my_resource_name", 1000) as lock:
14    if lock:
15        # Critical section: do something while the lock is held
16        print("Lock acquired, performing work...")
17    else:
18        # Lock could not be acquired
19        print("Failed to acquire lock")