fastapi 异步调用

使用 FastAPI 进行异步调用需要使用 Python 的异步特性，例如使用 async/await 关键字和 asyncio 库。以下是使用 FastAPI 进行异步调用的示例代码：

from fastapi import FastAPI
from fastapi.responses import HTMLResponse
import httpx

app = FastAPI()

@app.get("/", response_class=HTMLResponse)
async def root():
    async with httpx.AsyncClient() as client:
        response = await client.get("https://www.example.com")
        return response.text

在这个示例中，我们使用了 httpx 库进行异步 HTTP 请求，并在 FastAPI 的路由函数中使用了 async/await 关键字。为了启用异步支持，我们将返回的响应类型设置为 HTMLResponse，并将函数定义为 async。

除了使用异步库外，还可以使用 FastAPI 内置的异步支持。例如，使用 asyncpg 库进行异步 PostgreSQL 数据库访问的示例代码如下：

import asyncpg
from fastapi import FastAPI

app = FastAPI()

@app.on_event("startup")
async def startup():
    app.state.pool = await asyncpg.create_pool("postgresql://user:password@localhost/dbname")

@app.get("/")
async def read_root():
    async with app.state.pool.acquire() as connection:
        result = await connection.fetch("SELECT 1")
        return {"result": result}

在这个示例中，我们在 FastAPI 的应用程序启动事件中创建了一个异步 PostgreSQL 连接池，并在路由函数中使用了 async/await 关键字进行异步查询。