Module for working with PostgreSQL via asyncpg
Project description
aioworkers-pg
Asyncpg plugin for aioworkers
.
Usage
Add this to aioworkers config.yaml:
db:
cls: aioworkers_pg.base.Connector
dsn: postgresql:///test
You can get access to postgres anywhere via context:
await context.db.execute('CREATE TABLE users(id serial PRIMARY KEY, name text)')
await context.db.execute(users.insert().values(name='Bob'))
Storage
storage:
cls: aioworkers_pg.storage.RoStorage
dsn: postgresql:///test
table: mytable # optional instead custom sql
key: id
get: SELECT * FROM mytable WHERE id = :id # optional custom sql
format: dict # or row
Development
Install dev requirements:
poetry install
Run postgres:
docker run --rm -p 5432:5432 --name postgres -e POSTGRES_PASSWORD=postgres -e POSTGRES_DB=test -d postgres
Run tests:
pytest
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
aioworkers-pg-0.2.1a8.tar.gz
(8.0 kB
view hashes)
Built Distribution
Close
Hashes for aioworkers_pg-0.2.1a8-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 9bacb0ebbb55f091d1ea7840c2baafc80b0df46f91477ee1ffad1dfea58d3a65 |
|
MD5 | 9a93dd9c7520c6cee64d3cb0815248c4 |
|
BLAKE2b-256 | 97a0a9e3114d11cef29409b2ec60904b639aa757f947eb2ebd8ba04fc2bbd22e |