任务调度服务

Question

我们需要一种可以用来安排活动的服务。例如，我们可能有一项任务需要在 3 点钟运行（一次）或每 2 小时运行一次（多次）。最好每个任务都可以配置一个 AMQP 队列，它将发布到。

我们可以通过创建操作系统计时器事件轻松实现这一点。我担心的是如果这项服务出现故障，如何恢复。如果允许即时调度，我们可以使用 CRON。

我一直在寻找一种方法来避免重新发明轮子。如果还没有一个项目可以做到这一点，我们将创建一个。不过，这是一件很常见的事情，所以如果现在还没有人把它放在那里，我会感到惊讶。

Answer 1

Celery 解决了这个问题。

celery.schedules 允许您定义周期性任务。您可以覆盖is_due 来执行schedule once a month 之类的操作。您可以使用periodic_task 或celery-beat 来schedule tasks to execute at a specific time（我相信这是现在的标准方法）。还有一种方法是使用eta 参数到Task.apply_async。