1 files changed, 21 insertions, 0 deletions
diff --git a/python/experiments/test_asyncpg.py b/python/experiments/test_asyncpg.py
new file mode 100644
index 00000000..315c82c8
--- /dev/null
+++ b/python/experiments/test_asyncpg.py
@@ -0,0 +1,21 @@
+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()))