Celery Beat 运行重复任务

Question

我有一个 celery beat 任务，即运行其他抓取任务。 当这些任务未被处理时，队列开始增长。

我知道 celery 使用后端数据库，但只有：id，task_id，status，result，date_done，traceback。

我的想法是从 celery beat 切换到自己重新安排任务，但是有些任务没有关联或者可能会丢失，所以 celery beat 在这些情况下很有用。

第二个想法是添加我的日志，比如我的表，我可以在其中保存任务 ID 和任务上下文，通过它们我将能够找出任务是否已经存在。

你有更好的方法吗？谢谢

Answer 1

celery 任务可以是 delayed 和 expires 参数： http://docs.celeryproject.org/en/latest/userguide/calling.html#expiration