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
我想将 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