python - 如果任务没有运行超过 10 分钟,如何重新安排任务?

标签 python django celery django-celery

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

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

最佳答案

尝试 acks_late 设置 CELERY_ACKS_LATE ,任务执行后会确认任务消息。这样您就可以更轻松地重新运行任务。

关于python - 如果任务没有运行超过 10 分钟,如何重新安排任务?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7807417/

相关文章:

python - 在计算 networkx 中的传出和传入边缘时,len 抛出 'dict_keyiterator' 没有 len()

python - 在 Django 中实现长时间运行的子进程的最佳方式?

django - Celery 4.2-Django 递归错误 : maximum recursion depth exceeded

javascript - 在node.js和django之间共享数据的最佳方式?

javascript - 如何将图像位置放入 django 模板中的 javascript 代码中

django - 将自定义方法添加到模型时发生错误(来自 Django 教程)

python - 开始 celery : AttributeError: 'module' object has no attribute 'celery'

python - Celery:有没有办法编写自定义 JSON 编码器/解码器?

python - 如何在内存中复制 tensorflow 网络状态以便参数更新后检索?

python - 是否有一种灵活的方法可以通过从形状文件读取或使用一组顶点创建的多边形来裁剪光栅?