将 POST 请求从 Flask 传递到 Celery 任务
我在 Flask 中有一个很长的 csv 文件上传任务，由于它很长，我想让 Celery 在后台处理它，但是如何将此请求从 Flask 路由传递到 Celery 任务？ 为了构…
将 Python 版本 3.6 更改为 3.10 后，我得到 Cannot import name 'Callable'来自“收藏”；
File "C:\Users\Codertjay\PycharmProjects\Teems_App_Kid\teems_app_kid\__init__.py", line 5, in from .celery import app as celery_app File "C…
需要从celery共享任务队列进程中返回对象
遇到了错误“kombu.exceptions.EncodeError：'JsonResponse'类型的对象不是 JSON 可序列化的” 我在 settings.py 中 CELERY_BROKER_URL = 'amqp://loc…
Celery 在任务内异步运行子任务并等待结果
我有一个 celery 任务，可以启动其他三个 celery 任务。我希望这些任务异步执行并等待它们完成，然后再恢复父任务。然而，子任务正在同步运行，我不知…
如何使 celery 任务从任务内部失败？
在某些情况下，我想让芹菜任务从该任务中失败。我尝试了以下操作： from celery.task import task from celery import states @task() def run_simula…
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…
