问题标签 [celery-task]

I installed django-celery and I tried to start up the worker server but I get an OSError that a function isn't implemented. I'm running CentOS release 5.4 (Final) on a VPS:

Am I just totally screwed or is there an easy way to resolve this?

我希望能够中止从芹菜队列运行的任务（使用rabbitMQ）。我使用

其中 AsyncBoot 是一个已定义的任务。

我可以获取任务 ID（假设是apply_async返回的长字符串）并将其存储在数据库中，但我不确定如何调用中止方法。我看到如何使用 Abortable 任务类使方法可中止，但如果我只有任务 ID 字符串，我如何在任务上调用 .abort() ？谢谢。

我正在尝试使用 Celery 的AbortableTask功能，但文档示例似乎对我不起作用。给出的例子是：

和

但是，我收到错误：

我究竟做错了什么？

我有两个芹菜工人，工人 1 有任务 A 和 B，工人 2 有任务 A、B 和 C。如果我提交任务 C，它似乎没有在有任务 C 的芹菜工人中执行；有什么方法可以确保只有工人 2 被分配任务 C？

如何测试任务（task_id）是否仍在celery中处理？我有以下情况：

1. 在 Django 视图中启动任务
2. 将 BaseAsyncResult 存储在会话中
3. 关闭 celery 守护进程（硬），因此不再处理任务
4. 检查任务是否“死亡”

有任何想法吗？是否可以查找 celery 正在处理的所有任务并检查我的任务是否仍然存在？

我开始使用 celery，我想知道是否可以将模块添加到已经启动的 celeryd 进程中。换句话说，而不是像通过 celeryconfig.py 添加模块

在启动工作人员之前，我想在工作进程启动后以某种方式使附加模块可用。

提前致谢。

我正在使用 Django 和 Celery + RabbitMQ 来创建用户上传的视频的视频转换任务。现在我知道如何查询 celery 以获取状态。我的问题是在哪里保存与每个任务关联的 task_id，我应该将它保存在模型中还是 django 的缓存中？

我知道过去曾提出过类似的问题，例如这个 stackoverflow 问题，但还没有明确的答案。我知道这个问题的答案因开发人员的喜好而异，但如果有人可以就不同方法的优缺点进行教育，那就太好了。

只是为了重新迭代，我将使用 task_id 每隔一段时间从前端触发 AJAX 查询，以了解视频转换是否完成。

我已经启动了很多任务，但其中一些还没有完成（763 个任务），处于 PENDING 状态，但系统没有处理任何事情......可以重试这个任务，给 celery 任务 ID？

add 是 celery doc 的任务。我只是很困惑为什么它没有像它应该的那样产生 8，而是除了挂起什么都不做。

如何在不知道task_id每个任务的情况下删除所有待处理任务？