如何启动一个只向代理推送任务但不消费它们的celery worker?

How to start a celery worker that only pushes tasks to the broker but does not consume them?

我在一个网络服务器上有一个主要的任务生产者。我不希望网络服务器消耗任何任务,因此它应该只将任务发送给被其他节点消耗的代理。

现在我通过为每个节点指定特定队列,在节点中使用 -Q 选项路由任务。有没有办法为一个工作人员指定 0 个队列?

感谢任何帮助,谢谢!

您不需要使用 worker 将任务推送到代理 - 您可以从常规 python 流程中完成。