Question

在sync上使用快车牌,而不是<条码>。顺便说一句,我谨收到一份无改动的无资格证书申请。

All examples I can find show async code, when I try it in a normal sync way, the request.body() shows up as a coroutine object.

当我通过将一些<代码>XML上贴到这个终点时,我收到一份<代码>500“Internal服务器 Error”。


from fastapi import FastAPI, Response, Request, Body

app = FastAPI()

@app.get("/")
def read_root():
    return {"Hello": "World"}

@app.post("/input")
def input_request(request: Request):
    # how can I access the RAW request body here?  
    body = request.body()

    # do stuff with the body here  

    return Response(content=body, media_type="application/xml")

Is this not possible with FastAPI?
注:简化投入请求将考虑:
POST http://127.0.0.1:1083/input
Content-Type: application/xml

<XML>
    <BODY>TEST</BODY>
</XML>

我没有控制如何发出投入要求,因为我需要取代现有的《社会行动计划》的预报。

Answer 1


Using async def endpoint
<205> 例如:
from fastapi import Request

@app.post("/input")
async def input_request(request: Request):
    return await request.body()

Update 1 - Using def endpoint

或者,如果你相信新数据是有效的<代码>JSON,则你可以将结尾点与<代码>def加以界定,并使用>>>:>Body数据,见

from fastapi import Body

@app.post("/input")
def input_request(payload: dict = Body(...)):
    return payload

但是,如果输入的数据载于XML/code>格式,如你提供的例子,一种选择是使用> 编码,只要你控制客户数据如何发送给服务器(请查询

from fastapi import File

@app.post("/input") 
def input_request(contents: bytes = File(...)): 
    return contents


Update 2 - Using def endpoint and async dependency

如,。从请求中删除<代码>。您也可使用<代码>sync Dependencies on non-async (i.e.,def) endpoints。因此,如果在此结尾处存在某种阻塞代码,则阻止你使用>。我猜想这或许是你的理由——这是前进的道路。

注:我还应提及:,该回答是——其中解释了def和sync def终点(你可能知道)之间的区别——也提供了在您需要使用<条码>Aasync def时的解决办法。 (由于您可能需要在一条线路上安装有关校正的<代码>await<>/code>),但也有一些synchronous 昂贵的CPU限制操作,可能会阻挡服务器。请看一看。

上文描述的办法实例如下。如果你要确认,请求获得的笔数将阻碍通过 sync def 。

from fastapi import FastAPI, Depends, Request
import time

app = FastAPI()

async def get_body(request: Request):
    return await request.body()

@app.post("/input")
def input_request(body: bytes = Depends(get_body)):
    print("New request arrived.")
    #time.sleep(5)
    return body

Answer 2

为方便起见,您仅可使用asgiref ,本套支持async_to_sync和sync_to_async:

from asgiref.sync import async_to_sync

sync_body_func = async_to_sync(request.body)
print(sync_body_func())

async_to_sync 在一次活动时执行同文职能,sync_to_async 在校友中履行yn功能。

Update 2 - Using `def` endpoint and `async` dependency

Using `async def` endpoint

Update 1 - Using `def` endpoint

友情链接