Django-Celery - 从管理页面重新提交任务？

Question

我目前正在开发一个使用 Django 1.3 和 Django-Celery 应用程序的项目。非常棒，顺便说一句，我建议任何不熟悉芹菜的人都看看。

我对管理页面功能有一个具体问题：

我们正在使用 celery 任务向第三方合作伙伴进行 RESTful API 调用。这些调用实际上是由用户操作启动的，因此您可以看到 celery 任务在这种情况下非常有用。

我们有一个关于管理员如何在由于某种原因失败时重新发送回调的用户故事。现在，如果回调因标准 HTTP 响应失败而失败，我们将使用 celery 重试机制以不同的时间间隔自动重新发送它们。然而，这些回调可能是针对数千个合作伙伴之一（是的，有很多），并且并非所有合作伙伴都会使用标准 HTTP 响应代码作为其失败响应。

长话短说，我在网上找不到任何可以通过管理界面重新发送芹菜任务的内容。我希望有人能对此有所启发。这似乎是一个非常明显的功能，如果没有这样的功能，我相信这是有充分理由的。如果没有办法做到这一点，如果有人可以解释原因，我会很高兴。只是想了解更多有关 celery 内部工作原理的信息。

谢谢大家！抱歉我的啰嗦，有时我会胡言乱语。

Answer 1

您可以尝试两种方法，

1：模型中的小技巧：

您可以使用布尔字段并将其命名为 celery_retry 之类的名称，并在模型保存方法中执行类似的操作。

def save(self, *args, **kwargs):
    if self.celery_retry and self.user.is_superuser():
          celery_task.apply_async()
    self.celery_retry = False
    super(MyModel, self).save(*args, **kwargs)

这只是一个想法，你可以自己决定如何以及何时提交回 celery 任务。

2：扩展管理模板：

您可以扩展管理模板并放入指向重新提交任务的视图的超链接。