python - 如何让 Celery worker 消耗单个任务并退出

Question

如何使celery -A app worker命令仅使用单个任务然后退出。

我想将 celery 工作人员作为 kubernetes 作业运行，该作业在处理单个任务后完成。

我正在使用 KEDA 根据队列消息自动缩放工作人员。我想将芹菜工人作为长时间运行的任务的工作，如文档中所建议的那样： KEDA long running execution

Answer 1

没有什么具体的。您可能必须通过自定义并发模块破解您自己的驱动程序。您是否尝试使用 Keda ScaledJobs 或其他什么？您只需使用 ScaledObject 代替。