SQLAlchemy 1.4 / 2.0 support for aiohttp.

The library provides the next features:

  • initializing asynchronous sessions through a middlewares;
  • initializing asynchronous sessions through a decorators;
  • simple access to one asynchronous session by default key;
  • preventing attributes from being expired after commit by default;
  • support different types of request handlers;
  • support nested applications.



pip install aiohttp-sqlalchemy

Simple example

Install aiosqlite for work with sqlite3:

pip install aiosqlite

Copy and paste this code in a file and run:

from aiohttp import web
import aiohttp_sqlalchemy
from aiohttp_sqlalchemy import sa_session
from datetime import datetime
import sqlalchemy as sa
from sqlalchemy import orm

metadata = sa.MetaData()
Base = orm.declarative_base(metadata=metadata)

class MyModel(Base):
    __tablename__ = 'my_table'

    pk = sa.Column(sa.Integer, primary_key=True)
    timestamp = sa.Column(sa.DateTime(),

async def main(request):
    db_session = sa_session(request)

    async with db_session.begin():
        stmt =
        result = await db_session.execute(stmt)
        items = result.scalars()

    data = {}
    for item in items:
        data[] = item.timestamp.isoformat()

    return web.json_response(data)

async def app_factory():
    app = web.Application()

    aiohttp_sqlalchemy.setup(app, [
    await aiohttp_sqlalchemy.init_db(app, metadata)

    app.add_routes([web.get('/', main)])

    return app

if __name__ == '__main__':