有两种方法可以实现这一点
1.使用celery进行事件的异步处理（它确实支持它）
1.将async和await与事件处理函数一起使用
正如您提到的，如果您希望在本机FAST API中使用某些功能，那么我认为最好使用async，并等待如下所示

async def get_event_done(event: list):
    # Do some asynchronous stuff to process the event
    return "event processed"

现在，让我们将上述函数与python内置库asyncio结合使用

futures = [get_event_done(event1), get_event_done(event2)]
event1_result,event_2_result = await asyncio.gather(*futures)

print("event 1 result", event1_result)
print("event 2 result", event2_result)

使用asyncio.gather收集结果非常简单和聪明

更多参考资料：

• FAST API异步，并等待
• Build an async python service with FastAPI & SQLAlchemy