我有以下代码: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 ...