django - 在没有更多任务要运行后，如何让 celery 死掉？

Question

我有一个内存密集型 celery 任务，我希望它在大部分时间都处于关闭状态的昂贵 AWS 服务器中运行。

celery 节拍将每天安排一次任务，但也可以通过网络应用程序(== django)手动安排。

调度任务就是向兔子队列发送消息。

然后我想使用 AWS api 发出一个命令来打开我昂贵的服务器，并让它启动工作人员，
等待它们在没有更多任务后死亡，然后关闭(因为服务器关闭，可以节省一些钱)。

我知道如何编写 AWS 脚本来打开我的服务器。问题是:我如何告诉 celery 运行任务直到队列为空 然后死 ?

有没有我可以给它的命令参数，或者我需要为此想出一些技巧吗？

Answer 1

celery worker 只是一匹笨马。如果工作人员正在等待任务，其他东西必须监视工作人员并触发事件。

使用 Flower监控您的 Celery 集群和 their API消耗 worker 事件。

Flower 有一个漂亮的仪表板，里面有 worker /任务数据，信息就在那里，他们有一个 API。