事实上,我有几个带有 celery 任务的 django 应用程序。我需要在特定 channel 内执行每个任务,以便我可以控制负载。例如,我可能有 3 个服务器监听 channel_for_app_1,两个服务器监听 channel_for_app_2。我的问题是如何运行 celery 守护进程并指定 channel ?还有其他方法吗?
请您参考如下方法:
请查看此页面:http://docs.celeryproject.org/en/latest/userguide/routing.html .
你的 celery 应该以 -Q, --queue 设置开始,它定义了哪个队列将用于获取任务
