9

我可能没有正确理解 FastAPI 中的异步概念。

我同时从两个客户端访问以下应用程序的根端点。我希望 FastAPIStarted在执行开始时连续打印两次：

from fastapi import FastAPI
import asyncio

app = FastAPI()

@app.get("/")
async def read_root():
    print('Started')
    await asyncio.sleep(5)
    print('Finished')
    return {"Hello": "World"}

相反，我得到以下内容，它看起来非常非异步：

Started
Finished
INFO: ('127.0.0.1', 49655) - "GET / HTTP/1.1" 200
Started
Finished
INFO: ('127.0.0.1', 49655) - "GET / HTTP/1.1" 200

我错过了什么？

4

5 回答 5

7

您如何确保有多个同时请求？

您的代码很好 - 尝试使用以下命令进行测试：

for n in {1..5}; do curl http://localhost:8000/ & ; done

您的浏览器可能正在缓存对同一 URL 的后续请求。

于 2020-03-05T16:06:16.223 回答
2

好吧，从这个 github 问题中的演示显示，这可能不是由于 FastAPI 而是运行请求的客户端。

于 2019-10-15T10:41:25.080 回答
2

我用 Chrome 浏览器做了同样的实验，结果和最初报道的一样。来自两个独立 Chrome 浏览器的请求被一个接一个地处理（好像是串行的）。

@app.get("/test")
async def test():
    r = {"message": "Hello by /test api"}
    r['timestamp'] = datetime.datetime.utcnow()
    await asyncio.sleep(10)
    return r

2 个请求需要 20 秒（每个 10 秒）才能完成整个过程，这显然不是并发方式！

但是，当我按照答案中的建议尝试时curl，它是并行处理的（！）

我用 2 个 Firefox 浏览器做了最后一个实验，结果也是并行执行。

最后，我从 FastAPI 的日志中找到了线索。当我尝试使用 2 个 Chrome 浏览器时，请求的来源 (ip:port) 记录相同

INFO:     10.10.62.106:54668 - "GET /test HTTP/1.1" 200 OK
INFO:     10.10.62.106:54668 - "GET /test HTTP/1.1" 200 OK

但是，如果我尝试使用 Firefox，则来源不同。

INFO:     10.10.62.106:54746 - "GET /test HTTP/1.1" 200 OK
INFO:     10.10.62.106:54748 - "GET /test HTTP/1.1" 200 OK

从上面的日志可以得出结论，FastAPI（或者前面的uvicorn）只有在源地址不同的时候才会并行处理请求。

请有人对上述结论发表评论。谢谢。

于 2021-06-29T02:20:19.143 回答
0

如果我理解正确，您尝试组合从不同请求执行的打印。您可能应该将 print("started") 实现为协程并以这种方式使用它：

async def started():
    print("Started")

@app.get("/")
async def read_root():
    await started()
    await asyncio.sleep(5)
    print('Finished')
    return {"Hello": "World"}

但它也不会像你想要的那样工作。如果您将困难的请求用于数据库连接、身份验证和其他计算，尤其是对第三方 API 的请求，您可以看到真正的异步。

祝你好运 ）

于 2020-06-10T08:48:54.813 回答
0

当您使用普通 def 而不是 async def 声明路径操作函数时，它会在外部线程池中运行，然后等待，而不是直接调用（因为它会阻塞服务器）。

您可以在本文中找到更多详细信息，其中我解释了在 FastAPI 中何处使用异步。

于 2021-09-14T17:29:07.987 回答