【发布时间】:2021-10-30 05:54:14
【问题描述】:
使用像下面这样的“正常”协同程序,结果是首先打印所有请求,然后在大约 5 秒后打印所有响应:
import asyncio
async def request():
print('request')
await asyncio.sleep(5)
print('response')
loop = asyncio.get_event_loop()
tasks = [
loop.create_task(request())
for i in range(30)
]
loop.run_until_complete(asyncio.wait(tasks))
loop.close()
我想在 FastApi 中复制相同的行为,所以我有这样的端点:
import asyncio
from fastapi import FastAPI
app = FastAPI()
@app.post("/")
async def root():
print('request')
await asyncio.sleep(5)
return 'OK'
我用来自前端的多个请求来轰炸它,如下所示:
const url = 'http://localhost:8000'
const data = [1, 2, 3]
const options = {
method: 'POST',
headers: new Headers({'content-type': 'application/json'}),
body: JSON.stringify({data}),
mode: 'no-cors',
}
for (let i=0; i<30; i++) {
fetch(url, options)
}
但是,在终端中我可以清楚地看到,FastAPI 一次只接受 6 个请求,为它们返回响应,然后再接受另外 6 个:
request
request
request
request
request
request
←[32mINFO←[0m: 127.0.0.1:63491 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:58337 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:50479 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:60499 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:56990 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:56107 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
request
request
request
request
request
request
←[32mINFO←[0m: 127.0.0.1:58337 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:63491 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:60499 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:56990 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:56107 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
←[32mINFO←[0m: 127.0.0.1:50479 - "←[1mPOST / HTTP/1.1←[0m" ←[32m200 OK←[0m
等等
这是因为某些 FastAPI/uvicorn 设置或限制吗?
数量是否可以增加,是否合理?
【问题讨论】:
-
您的应用运行情况如何?它只是通过一个简单的
uvicorn命令还是您使用pre-made FastAPI docker images 之一? -
我通过
uvicorn main:app --reload运行它
标签: asynchronous fastapi uvicorn