asyncpg-engine
Little wrapper around asyncpg for specific experience.
Basic usage
from asyncpg_engine import Engine
engine = await Engine.create("postgres://guest:[email protected]:5432/guest?sslmode=disable")
async with engine.acquire() as con:
# https://magicstack.github.io/asyncpg/current/api/index.html#asyncpg.connection.Connection
assert await con.fetchval("SELECT 1") == 1
Custom type conversions
You can specify custom encoder\decoder by subclassing Engine:
from asyncpg_engine import Engine
import orjson
class MyEngine(Engine):
@staticmethod
async def _set_codecs(con: Connection) -> None:
# https://magicstack.github.io/asyncpg/current/api/index.html#asyncpg.connection.Connection.set_type_codec
await con.set_type_codec(
"json", encoder=orjson.dumps, decoder=orjson.loads, schema="pg_catalog"
)
Development and contribution
First of all you should install Poetry using official instructions or solutions provided by your distro. Then install dependencies:
poetry install
Run PostgreSQL using provided docker-compose configuration:
docker-compose up # run it in another terminal or add `-d` to daemonize
Project uses combination of flake8, black, isort and mypy for linting and pytest for testing.
poetry run flake8
poetry run mypy ./
poetry run pytest
155 Dec 16, 2022
104 Nov 26, 2022
740 Dec 18, 2022
83 Dec 12, 2022
904 Jan 2, 2023
3.4k Jan 1, 2023
55 Dec 12, 2022
469 Jan 4, 2023
1.4k Jan 7, 2023
1.5k Jan 5, 2023
446 Dec 7, 2022
31 Dec 9, 2022
11.4k Jan 2, 2023
7 Dec 11, 2022
5 Jan 3, 2022
60 Jan 3, 2023
7.2k Jan 09, 2023
1.3k Dec 25, 2022
6 Jul 01, 2022
2 Oct 05, 2022
626 Dec 01, 2022
12 Jan 01, 2023
253 Dec 31, 2022
71 Nov 09, 2022
345 Dec 28, 2022
6 Oct 31, 2022
17 Oct 10, 2021
64 Oct 14, 2022
4 Apr 04, 2022
1.4k Dec 31, 2022
1.9k Dec 25, 2022
428 Dec 29, 2022
2.3k Jan 06, 2023
22.4k Dec 30, 2022
1 Jan 05, 2022
3.2k Jan 07, 2023