使用同一队列的多个工作人员的基于ID的芹菜队列



我对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将任务分配给队列。

刚刚发布了这个答案,所以如果可以帮助像我这样的芹菜新手的话。

相关内容

  • 没有找到相关文章

最新更新