sanic_aiopg_sqlalchemy_example.py 文件源码

def handle(request):
    async with engine.acquire() as conn:
        result = []
        async for row in conn.execute(polls.select()):
            result.append({"question": row.question, "pub_date": row.pub_date})
        return json({"polls": result})