我的服务器上有一个 Java API,我希望它创建任务并通过 RabbitMQ 将它们添加到 Celery。我遵循以下教程http://www.rabbitmq.com/tutorials/tutorial-two-python.html,其中我使用 java 作为客户端 (send.java) 和 python 接收 (receive.py)。在调用回调方法的receive.py 中,我调用了一个用@celery.task 注释的方法,以便将任务添加到芹菜中。
我想知道所有这些是如何部署在服务器上的,具体来说,为什么会有一个 receive.py 文件。receive.py 是必须在服务器上持续运行的进程吗?有没有办法配置 RabbitMQ 以便它自动将 java 客户端任务路由到 celery?
谢谢!