如果任务没有运行超过 10 分钟，如何重新安排任务？

Question

我有 task:recursive_task 它将安排相同的任务在 5 秒后执行，但如果由于某种原因该任务崩溃，则需要再次重新运行。 我几乎捕捉到了所有场景，但你永远不知道未来会发生什么。

我首先做了一个重复的任务：manage_tasks，它检查 recursive_task 的状态，并检查它是否长时间没有运行以及是否成功完成，但这感觉不对。那么你会如何解决这个问题呢？

Answer 1

尝试 acks_late 设置 CELERY_ACKS_LATE，它将确认任务消息任务执行后。有了这个，您可以更轻松地重新运行您的任务。

Answer 2

我建议看一下 python 信号：

http://docs.python.org/library/ signal.html

import signal

# Set the signal handler and an alarm
signal.signal(signal.SIGALRM, handler)
signal.alarm(900) # 15 miutes
# some_function()

signal.alarm(0)          # Disable the alarm

其中：

def handler(signum, frame):
    # do something
    sys.exit(1)

使用信号，您可以将处理程序设置为在您想要的任何时间后执行。然后，这是通过处理程序重新运行脚本的直接方法。