result.wait() 除了挂起之外什么也不做,并且对于 result=add.delay(4,4) 不给出 8
add 是来自 celery 文档的任务。我只是很困惑为什么它没有产生应有的 8 值,而是挂起而不执行任何操作。…
通过任务 ID 重试 celery 中的任务
我启动了很多任务,但其中一些尚未完成(763 个任务),处于 PENDING 状态,但系统未处理任何内容... 是否可以通过给 celery 提供 task_id 来重试此任…
从前端使用 AJAX 查询 Celery 以了解创建的任务是否完成的最佳方法?
我使用 Django 和 Celery + RabbitMQ 来创建用户上传的视频的视频转换任务。 现在我知道如何查询 celery 来获取状态。 我的问题是在哪里保存与每个任…
向现有的 celery 工作进程动态添加函数?
我正在开始使用 celery,我想知道是否可以将模块添加到已经启动的 celeryd 进程中。换句话说, CELERY_IMPORTS = ("tasks", "additional_module" ) 我…
测试 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