Aiopg Save

aiopg is a library for accessing a PostgreSQL database from the asyncio

Project README


.. image:: :target: .. image:: :target: .. image:: :target: :alt: Chat on Gitter

aiopg is a library for accessing a PostgreSQL_ database from the asyncio_ (PEP-3156/tulip) framework. It wraps asynchronous features of the Psycopg database driver.


.. code:: python

import asyncio
import aiopg

dsn = 'dbname=aiopg user=aiopg password=passwd host='

async def go():
    pool = await aiopg.create_pool(dsn)
    async with pool.acquire() as conn:
        async with conn.cursor() as cur:
            await cur.execute("SELECT 1")
            ret = []
            async for row in cur:
            assert ret == [(1,)]

loop = asyncio.get_event_loop()

Example of SQLAlchemy optional integration

.. code:: python

import asyncio from import create_engine import sqlalchemy as sa

metadata = sa.MetaData()

tbl = sa.Table('tbl', metadata, sa.Column('id', sa.Integer, primary_key=True), sa.Column('val', sa.String(255)))

async def create_table(engine): async with engine.acquire() as conn: await conn.execute('DROP TABLE IF EXISTS tbl') await conn.execute('''CREATE TABLE tbl ( id serial PRIMARY KEY, val varchar(255))''')

async def go(): async with create_engine(user='aiopg', database='aiopg', host='', password='passwd') as engine:

       async with engine.acquire() as conn:
           await conn.execute(tbl.insert().values(val='abc'))

           async for row in conn.execute(
               print(, row.val)

loop = asyncio.get_event_loop() loop.run_until_complete(go())

.. _PostgreSQL: .. _asyncio:

Please use::

$ make test

for executing the project's unittests. See for details on how to set up your environment to run the tests.

Open Source Agenda is not affiliated with "Aiopg" Project. README Source: aio-libs/aiopg
Open Issues
Last Commit
4 weeks ago

Open Source Agenda Badge

Open Source Agenda Rating