我有以下代码：import time from fastapi import FastAPI, Request app = FastAPI() @app.get("/ping") async def ping(request: Request): ...

问题 我们的处理服务为UI、API和内部客户提供服务，并监听来自Kafka的命令。一些API客户端可能会在短时间内创建大量生成任务（一个任务是N条消息）。由于每个命令都到达被一个处理实例(又称为worker)消费的分区，我们无法控制命令的分布。因此，UI请求可能需要等待太长时间，而API请求...

我阅读了微软的C#中使用async和await并发进行多个Web请求的操作方法，发现: private async Task CreateMultipleTasksAsync() { // Declare an HttpClient object, and increase ...