FastAPI 异步使用FastAPI，如何获取POST请求的原始body

在本文中，我们将介绍如何在FastAPI中以同步方式获取POST请求的原始body。

阅读更多：FastAPI 教程

异步和同步

FastAPI是一个基于Python类型提示和异步请求处理的现代Web框架。它支持异步请求处理，让你可以编写具有高性能和低延迟的后端服务。但是，有时候我们可能需要以同步方式处理请求。事实上，每个路由在FastAPI中都同时支持异步和同步的处理方式。

同步处理方式

默认情况下，FastAPI将请求处理为异步操作。但是，如果你希望以同步方式处理POST请求并获取原始body，可以使用Request.body()方法。

下面是一个示例代码，演示了如何以同步方式获取POST请求的原始body：

from fastapi import FastAPI, Request

app = FastAPI()

@app.post("/sync_endpoint")
def sync_endpoint(request: Request):
    body = request.body()
    return {"raw_body": body}

在上面的代码中，我们创建了一个路由/sync_endpoint，并指定了一个接受Request类型参数的处理函数sync_endpoint。在这个函数中，我们调用了Request.body()方法，以同步方式获取原始body，并将其作为响应返回。

示例

假设我们发送一个POST请求到/sync_endpoint，请求的body为{"name": "Alice", "age": 25}。通过上面的代码，我们可以得到以下响应：

{
  "raw_body": "{\"name\": \"Alice\", \"age\": 25}"
}

可以看到，我们成功地获取了原始的请求body。

异步处理方式

如果你希望继续以异步方式处理请求，但只是想获取原始body而不进行其他异步操作，可以使用Request.body()方法的异步版本Request.body()。

下面是一个示例代码，演示了如何以异步方式获取POST请求的原始body：

from fastapi import FastAPI, Request

app = FastAPI()

@app.post("/async_endpoint")
async def async_endpoint(request: Request):
    body = await request.body()
    return {"raw_body": body}

在上面的代码中，我们将处理函数async_endpoint定义为异步函数，并使用await关键字调用Request.body()方法，以异步方式获取原始body。

示例

假设我们发送一个POST请求到/async_endpoint，请求的body为{"name": "Alice", "age": 25}。通过上面的代码，我们可以得到以下响应：

{
  "raw_body": "{\"name\": \"Alice\", \"age\": 25}"
}

同样地，我们成功地获取了原始的请求body。

总结

FastAPI是一个现代化的Web框架，提供了丰富的异步请求处理能力。然而，如果我们需要以同步方式处理请求并获取原始body，可以使用Request.body()方法。同时，FastAPI也提供了异步版本的Request.body()方法，以便我们在异步处理中获取原始body。

通过本文的介绍和示例，你现在应该可以使用FastAPI以同步方式获取POST请求的原始body了。开始享受FastAPI带来的高性能和低延迟吧！