python-3.x - 如何在 python 中使用 asyncio 来避免回调地狱

Question

我有以下情况。
我有 3 个服务JobInitiator，它们以下列方式相互交谈Mediator。Executor

• JobInitiator每 X 分钟一次将请求的作业发布到队列 (RabbitMQ )
• 该Executor服务每 Y 分钟向该服务发送一个 REST API 调用，Mediator并询问是否有任何工作要完成。如果是这样 -Mediator从队列中拉出一条消息并在响应中将消息返回给Executor服务。
• 完成Executor作业执行后 - 他将作业结果Mediator发布到服务中的 API，该 API 将其发布到JobInitiator监听的队列。

旁注+限制和限制：

• 该Mediator服务只是我队列的 REST API 包装器。主要问题是Executor不能公开访问服务 - 只允许传出 api 调用。
• 我无法将队列直接从服务连接JobInitiator到Executor服务

到目前为止 - 这个过程并没有什么特别之处。我想知道的是是否可以在 python 中用 asyncio 编写它，所以我不会处理回调地狱。像这样的东西（伪代码）

class JobInitiator(object):
    def do_job():
        token = await get_token()
        applicative_results = await get_results(token=token)

whereget_token()和get_results()都经过上述过程。

标签： python-3.xrabbitmqpython-asyncioasynccallback