aiopg

What it is and what it does

aiopg is an asyncio driver for PostgreSQL that wraps psycopg2's synchronous interface to provide non-blocking database access. It lets you execute queries, manage transactions, and maintain connection pools without blocking the event loop—essential for async web frameworks and concurrent applications that need to query PostgreSQL.

The library supports both raw SQL execution via cursors and optional SQLAlchemy integration for ORM-style queries. It handles connection pooling, transaction management, and cursor operations asynchronously. Two runtime dependencies—psycopg2-binary and async-timeout—provide the underlying database driver and timeout handling.

Use it for

• Build async web services (FastAPI, aiohttp) that query PostgreSQL without blocking I/O.
• Implement concurrent batch processing where multiple coroutines execute database queries in parallel.
• Use SQLAlchemy ORM asynchronously by leveraging aiopg.sa for schema-driven database operations.
• Manage connection pools efficiently in long-running async applications to avoid resource exhaustion.
• Write async database migrations or data pipelines that process large datasets without halting the event loop.

Worth the install?

AI-flagged interpretation of the facts on this page. Verify before relying on it.

Install

aiopg on PyPI

Before you install

Low install friction with a pure-wheel distribution. Maintenance status is aging—last release was 2022-10-26 (1388 days ago)—but the repository remains active and unarchived. The package supports current Python versions (3.7–3.11) and has a stable production classifier.

Requires a running PostgreSQL server and psycopg2-binary (C extension) to be installed; psycopg2-binary must compile or a pre-built wheel must be available for your platform.

License in practice

BSD permissive license places no restrictions on use, modification, or distribution in proprietary or open-source projects.

Quickstart

import asyncio
import aiopg

async def query():
    pool = await aiopg.create_pool('dbname=mydb user=user password=pass host=localhost')
    async with pool.acquire() as conn:
        async with conn.cursor() as cur:
            await cur.execute('SELECT 1')
            async for row in cur:
                print(row)

asyncio.run(query())

Package facts

Evidence: aiopg-1.4.0-py3-none-any.whl

Tags

More Database packages

See also aiomysql · hopsworks-aiomysql · aioodbc · databases · aiosqlite · opentelemetry-instrumentation-aiopg · psycopg · postgres · psycopg2 · aiosmtplib