django - 如何在 django celery 中处理未完成的任务

Question

我正在开发一个项目，其中用户上传 zip/gzip 文件，然后使用 Celery 解压缩和处理。该网站基于 Django。现在我面临的问题是当 Celery 没有运行时上传的文件很少。无论如何，我可以为这些未处理的文件重新运行 celery 吗？如果是这样，那怎么办？

谢谢。

Answer 1

您必须手动跟踪这些任务并从Django shell. celery 创建了很多表来跟踪这些任务。我已经有一段时间没有使用芹菜了，但我的猜测仍然是：

djcelery_crontabschedule

djcelery_taskstate

芹菜文档中也可能有一些关于此的内容：http: //docs.celeryproject.org/en/2.3/getting-started/first-steps-with-celery.html

您也可以在 celery mailing list 上询问您的问题。