前提条件:有一个小的 celery 集群处理一些任务。每个 celery 实例都有很少的工作进程在运行。一切都在 flask 下运行。
任务:我需要能够从代码中的特定节点暂停/恢复使用任务。 IE。任务可以决定当前的 celery 实例及其所有工作人员是否应该暂停或恢复任务的消耗。
没有找到任何直接的方法来解决这个问题。有什么建议吗？
提前致谢!
最佳答案
Control.cancel_consumer(queue, **kwargs) ( reference ) 就是您的用例可能需要的全部内容。
关于flask - 让celery停止消耗任务，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/10193942/