A very simple distributed advisory locking primitive using Redis.
>>> f = DistributedLockFactory(prefix="locks|")
>>> with f(12345) as l:
... # Protected block. Subsequent attempts to lock this
... # key `locks|12345` will block.
... assert l.key == 'locks|12345'Distlock is in use as a very simple mechanism to avoid race conditions among instances of microservices which can in partial failure conditions try to start the same chunk of work.
Redis affords us a very mechanism for atomic synchronisation among network-attached processes. Because it is a single-process event-driven service, all individual operations on it are by definition atomic enabling us to build a locking mechanism over it.
Implementations in other languages to come.
--------- | ---------
master |
- Python3 support