В aiopg есть поддержка асинхронной работы с SQLAlchemy:

import asyncio

from aiopg.sa 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 go():

engine = await create_engine(user='aiopg',

database='aiopg',

host='127.0.0.1',

password='passwd')

with (await engine) as conn:

await conn.execute(tbl.insert().values(val='abc'))

res = await conn.execute(tbl.select().where(tbl.c.val=='abc'))

for row in res:

print(row.id, row.val)

asyncio.run(go())