在 FastAPI 中,您可以定义处理各种类型请求正文的端点,例如JSON 或表单数据。这允许您创建可以接受任一格式的端点,而无需单独的端点。
要实现此目的,您可以遵循以下方法之一:
您可以利用依赖函数来验证请求的 Content-Type 标头,然后使用 Starlette 的方法适当地解析正文。请注意,仅依赖 Content-Type 标头可能无法始终保证请求正文的有效性,因此建议包含错误处理。
<code class="python">import os, sys from fastapi import FastAPI, Depends, HTTPException from starlette.requests import Request app = FastAPI() # Generating file open("./app.txt", "w").write("hello from a file") async def body_parser(request: Request): ct = request.headers.get("Content-Type", "") if ct == "application/json": try: d = await request.json() if not isinstance(d, dict): raise HTTPException(status_code=400, details={"error":"request body must be a dict"}) return d except JSONDecodeError: raise HTTPException(400, "Could not parse request body as JSON") elif ct == "multipart/form-data": await request.stream() # this is required for body parsing. d = await request.form() if not d: raise HTTPException(status_code=400, details={"error":"no form parameters found"}) return d else: raise HTTPException(405, "Content-Type must be either JSON or multipart/form-data") @app.post("/", dependencies=[Depends(body_parser)]) async def body_handler(d: dict): if "file" in d: return {"file": d["file"]} return d</code>
在此方法中,您可以在端点中将表单/文件参数定义为可选。如果这些参数中的任何一个具有值,则它假定是表单数据请求。否则,它将验证请求正文为 JSON。
<code class="python">from fastapi import FastAPI, Form, File, UploadFile app = FastAPI() @app.post("/") async def file_or_json( files: List[UploadFile] = File(None), some_data: str = Form(None) ): if files: return {"files": len(files)} return {"data": some_data}</code>
您还可以创建单独的端点,一个用于 JSON,另一个用于表单数据。使用中间件,您可以检查 Content-Type 标头并将请求重新路由到适当的端点。
<code class="python">from fastapi import FastAPI, Request, Form, File, UploadFile from fastapi.responses import JSONResponse app = FastAPI() @app.middleware("http") async def middleware(request: Request, call_next): ct = request.headers.get("Content-Type", "") if ct == "application/json": request.scope["path"] = "/json" elif ct in ["multipart/form-data", "application/x-www-form-urlencoded"]: request.scope["path"] = "/form" return await call_next(request) @app.post("/json") async def json_endpoint(json_data: dict): pass @app.post("/form") async def form_endpoint(file: UploadFile = File(...)): pass</code>
此外,您可以在 Stack Overflow 上找到这个答案很有帮助,因为它提供了在单个端点中处理 JSON 和表单数据的不同视角:
https://stackoverflow.com/a/67003163/10811840
出于测试目的,您可以使用请求库:
<code class="python">import requests url = "http://127.0.0.1:8000" # for testing Python 3.7 and above use: # url = "http://localhost:8000" # form-data request files = [('files', ('a.txt', open('a.txt', 'rb'), 'text/plain'))] response = requests.post(url, files=files) print(response.text) # JSON request data = {"some_data": "Hello, world!"} response = requests.post(url, json=data) print(response.text)</code>
这些方法提供了不同的方法来创建可以处理 JSON 和表单的端点-FastAPI 中的数据。选择最适合您的要求和用例的方法。
以上是如何创建接受表单或 JSON 正文的 FastAPI 端点?的详细内容。更多信息请关注PHP中文网其他相关文章!