如何在flask中创建postgress的异步查询？

from flask import Flask, request
import asyncpg
import asyncio

app = Flask(__name__)

@app.route('/query', methods=['POST'])
async def query():
    # 获取请求中的查询参数
    query_param = request.form.get('query_param')
    
    # 创建异步数据库连接池
    conn = await asyncpg.create_pool(database='your_database', user='your_user', password='your_password', host='your_host')
    
    # 执行异步查询
    async with conn.acquire() as connection:
        result = await connection.fetch(query_param)
    
    # 关闭数据库连接
    await conn.close()
    
    # 返回查询结果
    return str(result)