aioworkers-pg 0.2.0

Module for working with PostgreSQL via asyncpg

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:

pipenv install --dev --skip-lock

Run tests:

pytest