Since ETCD 0.4, all the built in modules were removed, including the locking module. The API still provides an atomic compare-and-swap method to implement locking, thus providing the core functionality to create semaphores and mutexes. This library is built on top of that, matching the API that was in python-etcd before it was removed as much as possible.
import etcd
from etcdlock import Lock
lock = Lock(etcd.Client(), 'path/to/my/key')
while lock
# lock is acquired
# lock will renew itself by default until released
# do work
request = ....
# check if we still have the lock
if lock.is_locked() is False:
returnimport etcd
from etcdlock import Lock
client = client = etcd.Client(host='api.example.com', protocol='https', port=443, version_prefix='/etcd')
lock = Lock(client, 'path/to/my/key', ttl=30, renewSecondsPrior=)
if lock.acquire(timeout=20):
t = Thread(target=someheavywork)
t.run()
t.wait()
lock.renew()
# some other work
lock.release() # not recommended, use a context manager
else
# failed to acquire the lock in 20 seconds
passPlease see the tests while the documentation is lacking, thanks.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent