fastapi - asyncpg

test.py

async def setup_database():
    global connection_pool
    connection_pool = await asyncpg.create_pool(
        user=os.getenv('PGUSER', 'x'),
        password=os.getenv('PGPASS', 'xx'),
        database='xx',
        host='xxx',
        port=5432
    )   
    
connection_pool = None

app = FastAPI()

@app.on_event("startup")
async def startup():
    await setup_database()


@app.get("/ir/", response_model=List[Note])
async def read_notes():
    async with connection_pool.acquire() as connection:
        await connection.execute("SET search_path TO 'xx'")
        data = await connection.fetch(READ_IR_SQL)
    print("data", data)
    return {'data': 'gee'}