rabbitmq - Celery 任务计划(Celery、Django 和 RabbitMQ)

Question

我想要一个每 5 分钟执行一次的任务，但它会等待最后一次执行完成，然后开始计算这 5 分钟。 (这样我也可以确定只有一个任务正在运行)我发现的最简单的方法是运行 django application manage.py shell 并运行:

while True:
    result = task.delay()
    result.wait()
    sleep(5)

但是对于我想以这种方式执行的每个任务，我必须运行它自己的 shell，有没有一种简单的方法可以做到这一点？可能是一些国王定制的 ot django celery 调度程序？

Answer 1

哇，令人惊讶的是没有人理解这个人的问题。他们问的不是定期运行任务，而是如何确保 Celery 不会同时运行同一任务的两个实例。我认为没有办法直接用 Celery 来做到这一点，但你可以做的是让其中一个任务在开始时获取锁，如果失败，则在几秒钟内重试(使用重试) 。任务将在返回之前释放锁；如果锁崩溃或超时，您可以使锁在几分钟后自动过期。

对于锁，您可能可以使用数据库或 Redis 之类的东西。