python - 任务调度服务

Question

我们需要一项可用于安排事件的服务。例如，我们可能有一个任务需要在 3 点运行(一次)或每 2 小时运行一次(多次)。最好每个任务都可以配置一个要发布到的 AMQP 队列。

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

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

Answer 1

Celery解决了这个问题。

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