A distributed lock implementation based on SQLAlchemy
Project description
SQLAlchemy-DLock
Distributed lock based on Database and SQLAlchemy.
It currently supports locks of:
MySQL
: https://dev.mysql.com/doc/refman/8.0/en/locking-functions.htmlPostgreSQL
: https://www.postgresql.org/docs/current/explicit-locking.html#ADVISORY-LOCKS
It's not stable and DO NOT use it in production.
Usages
Basic usage:
# ...
from sqlalchemy import create_engine
from sqlalchemy_dlock import sadlock
# ...
lock_key = 'user/001'
# ...
engine = create_engine('postgresql://scott:tiger@localhost/')
# ...
with engine.connect() as conn:
with sadlock(conn, lock_key):
pass
# locked here!
# ...
pass
# unlocked here!
# ...
# ...
Work with SQLAlchemy's Session:
# ...
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy_dlock import sadlock
# ...
lock_key = 'user/001'
# ...
engine = create_engine('postgresql://scott:tiger@localhost/')
Session = sessionmaker(bind=engine)
# ...
session = Session()
# ...
with session.bind.connect() as conn:
with sadlock(conn, lock_key):
# locked here!
# ...
user = session.query('User').filter(id='001').one()
user.password = 'new password'
session.commit()
# ...
pass
# unlocked here!
# ...
# ...
CHANGELOG
0.1.3
Date: 2021-11-09
- New:
- Better supportings for SQLAlchemy 1.4+, and Scoped Session.
- New
level
argument for PostgreSQL lock.
v0.1.2
Date: 2021-01-26
Still an early version, not for production.
- Changes:
- Arguments and it's default value of
acquire
now similar to stdlib'smultiprossing.Lock
, instead ofThreading.Lock
- MySQL lock now accepts float-point value as
timeout
- Arguments and it's default value of
- Adds
- Several new test cases
- Other
- Many other small adjustment
v0.1.1
- A very early version, maybe not stable enough.
- Replace black2b with crc64-iso in PostgreSQL key convert function
- Only named arguments as extra parameters allowed in Lock's implementation class
AUTHORS
-
Liu Xue Yan (liu_xue_yan@foxmail.com)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
SQLAlchemy-DLock-0.1.3.tar.gz
(9.5 kB
view hashes)
Built Distribution
Close
Hashes for SQLAlchemy_DLock-0.1.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 983cc2d84308ea043c804666e77f8963c53ecd9892292141ac499c84aad9e400 |
|
MD5 | 158bd844aeccf265c8519345bf117ae0 |
|
BLAKE2b-256 | 0a31634292c22c244db9286b1dd1649d63ce455c59706f999f675651e15c4eac |