celery control add_consumer giving Error: No nodes replied within time constraint

celery control add_consumer giving Error: No nodes replied within time constraint

我想将 celery worker 配置为仅从特定队列消费, 我在芹菜文档中看到 control add_consumer 正是这样做的。 问题是当我尝试时: celery control -A [App_name] add_consumer [queue_name] worker1.h% 它给我错误:

Error: No nodes replied within time constraint

非常感谢您的帮助。 有没有其他方法可以让我的工作人员从特定队列消费?

注意:celery -A [App_name] worker1.h% 启动 celery worker,一切正常,只是在我的所有队列中都有效。我想指定一个工作人员从特定队列中消费。 使用的经纪人:rabbitmq

我只想运行一个单独的工人

celery -A app_name -Q queue_name --concurrency=1