python - 不同 Docker 容器中不同 python 应用程序的 celery 任务

Question

我已经阅读官方 Celery 的 docs , DigitalOcean 的 tutorial然后运行得很好examples .但我无法理解我的应用程序如何像在 Resque Ruby 中那样进行通信。例如，我在 docker 容器中有主要的 python 应用程序，它必须为其他容器中的 2 个其他 python 应用程序生成任务。在 Resque 中，我的应用程序只是监听一些队列并接受任务，然后做一些工作并推回响应。

Answer 1

Celery 还需要一个队列/代理来在应用程序进程和工作进程之间进行通信。参见 http://docs.celeryproject.org/en/latest/getting-started/brokers/index.html对于受支持的代理(RabbitMQ 通常用于此)。

应用程序进程将新任务发布到代理上的队列，工作人员将在工作人员有可用容量时立即从队列中获取它。

您说您需要将任务传递给另外两个 Python 应用程序。可以让这些 Python 应用程序监听两个不同的队列并处理它们。