我对celele和构建一个监控应用程序很陌生,在该应用程序中,主服务器将使用celele与rabbitmq获取所有客户端节点服务器状态。
我已经学会了如何使用芹菜发送和接收任务,但仍坚持使用多个服务器的单个队列。
例如,如果我在所有中有200台服务器
将创建10个队列,每个队列将处理20个服务器。
[rabbitmq_queue1....10]
我的问题是,当一个芹菜工作者开始监听一个特定的队列时,它会获取队列中的所有任务
celery -A tasks worker -n celery_worker_A -Q rabbitmq_queue_1 --loglevel=DEBUG
那么,我怎么能给任务一个ID,让特定的工作人员只选择他的任务,剩下的就离开呢?
感谢您的时间和帮助!!!
因此,正如DejanLekic所建议的,我们不能根据不同的芹菜工人id将任务分配给队列。
刚刚发布了这个答案,所以如果可以帮助像我这样的芹菜新手的话。