MyTetra Share
Делитесь знаниями!
Использовать SQLAlchemy + PostgreSQL в асинхронном коде Python
02.02.2019
17:15
Автор: br0ke
Текстовые метки: python, async, asyncio, sqlalchemy, aiopg, pg, postgresql, postgres, postgre, psycopg2
Раздел: Информационные технологии - Python - Библиотеки - SQLAlchemy

В 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())


 
MyTetra Share v.0.52
Яндекс индекс цитирования