import asyncio import asyncpg import datetime async def dbconn(): conn = await asyncpg.connect(user='serenitas_user', password='Serenitas1', database='serenitasdb', host='debian') return conn async def get_singlenames_quotes_async(indexname, date): con = await dbconn() stmt = await con.prepare('SELECT * FROM curve_quotes($1, $2)') async with con.transaction(): # Postgres requires non-scrollable cursors to be created # and used in a transaction. async for record in stmt.cursor(indexname, date): print(record) await con.close() loop = asyncio.get_event_loop() loop.run_until_complete(get_singlenames_quotes_async("ig27", datetime.date.today()))