Tools to make Peewee work when using Asyncio
Project description
aio-peewee – Use Peewee with async framework
The library doesn’t make peewee work async, but allows you to use Peewee with your asyncio based libraries correctly.
Features
Tasks Safety. The library tracks of the connection state using asyncio.Task-local storage, making the Peewee Database object safe to use with multiple tasks inside a loop.
Async support for connections. Connect to database asyncroniously
Async support for Peewee Connections Pool
Requirements
python >= 3.8
Installation
aio-peewee should be installed using pip:
pip install aio-peewee
QuickStart
from aiopeewee import db_url
db = db_url.connect('postgres+async://locahost:5432/database')
async def main(id=1):
async with db:
item = Model.get(Model.id == 1)
return item.nameUsage
Initialization
from aiopeewee import PostgresqlDatabaseAsync, SqliteDatabaseAsync, MySQLDatabaseAsync, CockroachDatabaseAsync
db = MySQLDatabase('my_app', user='app', password='db_password', host='10.1.0.8', port=3306)Async Connect/Close
# Manual
async def main():
await db.connect_async()
# ...
await db.close_async()
# Context manager
async def main():
async with db:
# ...Connection Pooling
from aiopeewee import PooledPostgresqlDatabaseAsync, PooledSqliteDatabaseAsync, PooledMySQLDatabaseAsync, PooledCockroachDatabaseAsync
db = PooledPostgresqlDatabase('my_database', max_connections=8, stale_timeout=300, user='postgres')Database URL
from aiopeewee import db_url
db0 = db_url.connect('cockroachdb+async://localhost/db', **db_params)
db1 = db_url.connect('cockroachdb+pool+async://localhost/db', **db_params)
db2 = db_url.connect('mysql+async://localhost/db', **db_params)
db3 = db_url.connect('mysql+pool+async://localhost/db', **db_params)
db4 = db_url.connect('postgres+async://localhost/db', **db_params)
db5 = db_url.connect('postgres+pool+async://localhost/db', **db_params)
db6 = db_url.connect('sqlite+async://localhost/db', **db_params)
db7 = db_url.connect('sqlite+pool+async://localhost/db', **db_params)
db8 = db_url.connect('sqliteexc+async://localhost/db', **db_params)
db9 = db_url.connect('sqliteexc+pool+async://localhost/db', **db_params)Bug tracker
If you have any suggestions, bug reports or annoyances please report them to the issue tracker at https://github.com/klen/aio-peewee/issues
Contributing
Development of the project happens at: https://github.com/klen/aio-peewee
License
Licensed under a MIT license.
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 Distributions
Built Distribution
File details
Details for the file aio_peewee-0.0.4-py3-none-any.whl.
File metadata
- Download URL: aio_peewee-0.0.4-py3-none-any.whl
- Upload date:
- Size: 4.4 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.2.0 pkginfo/1.5.0.1 requests/2.24.0 setuptools/49.6.0 requests-toolbelt/0.9.1 tqdm/4.50.0 CPython/3.8.0
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 0bff6f5e9d7e30760609b2cb137c2b3142c7800efbcc5fbf9f2610c902203633 |
|
| MD5 | 787c698eeb3f52e5902fabe959c629be |
|
| BLAKE2b-256 | 7c5c579190a1ee24bce78d3bb7b8b018d6e4fd88355d07c939b8534496ac4d7a |
