测试 celery 任务是否仍在处理中
如何测试 celery 中是否仍在处理任务 (task_id)?我有以下场景: 在 Django 视图中启动任务 将BaseAsyncResult 存储在会话中 关闭 celery 守护进程(…
Django Celery AbortableTask 使用
我正在尝试使用 Celery 的 AbortableTask 功能,但文档例子似乎不适合我。给出的例子是: from celery.contrib.abortable import AbortableTask def M…
在 django 中中止 Celery 中正在运行的任务
我希望能够中止从 Celery 队列运行的任务(使用rabbitMQ)。我使用 AsyncBoot 来调用该任务, task_id = AsyncBoot.apply_async(args=[name], name=na…
Django Celery 实现 - OSError:[Errno 38] 函数未实现
我安装了 django-celery 并尝试启动工作服务器,但收到一个 OSError 消息,表明函数未实现。我在 VPS 上运行 CentOS 版本 5.4(最终版): . broker -…
- 共 1 页
- 1