FastAPI基础-协程

协程的概念

协程是一种轻量级的线程，它允许我们在同一个线程内并发地执行多个任务。在协程中，我们可以使用 async/await 语法来定义异步操作。例如，我们可以使用 async def 定义一个异步函数，并在函数中使用 await 关键字来等待异步操作的完成。

协程的优点在于它们可以在不同的任务之间切换而不需要进行线程切换，从而避免了线程切换的开销。另外，协程的内存占用也比线程要小得多，因为它们不需要为每个任务分配独立的内存空间。

在 FastAPI 中使用协程

在 FastAPI 中，我们可以使用协程来处理请求，以及执行异步操作。例如，在请求处理函数中，我们可以使用 async/await 语法来执行异步操作，例如读写文件、发送 HTTP 请求等。下面是一个示例：

from fastapi import FastAPI
import httpx

app = FastAPI()

@app.get("/")
async def index():
    async with httpx.AsyncClient() as client:
        response = await client.get("https://www.example.com")
    return {"status_code": response.status_code}

在上面的示例中，我们定义了一个根路由的请求处理函数 index，它使用异步的方式发送 HTTP 请求，并等待请求完成后返回响应状态码。使用 async with 语句创建了一个异步 HTTP 客户端，然后使用 await 关键字等待客户端发送的 HTTP 请求完成。

另外，在 FastAPI 中，我们还可以使用 async/await 语法来执行数据库操作。例如，如果我们使用 PostgreSQL 数据库，可以使用 asyncpg 库来实现异步访问。下面是一个示例：

import asyncpg

async def get_database_connection():
    conn = await asyncpg.connect("postgresql://user:password@localhost/mydatabase")
    return conn

@app.get("/users")
async def list_users():
    conn = await get_database_connection()
    rows = await conn.fetch("SELECT * FROM users")
    return [dict(row) for row in rows]

在上面的示例中，我们定义了一个异步函数 get_database_connection，用于连接到 PostgreSQL 数据库。然后我们在 list_users 请求处理函数中使用该函数来获取数据库连接，并使用 await 关键字等待数据库查询的结果。