有没有办法获取已注册任务的列表？ 我试过了： celery_app.tasks.keys() 它只返回内置的 Celery 任务，如 celery.chord、celery.chain 等。...

我的 ecs fargate celery beat 容器在部署后的几个小时内运行良好。 但过了一段时间，错误如下所示 Traceback (most recent call last): Fi...

我有一个以下项目目录： azima: __init.py main.py tasks.py task.py from .main import app @app.task def ad...

这就是我向芹菜工人发送任务并捕获生成的任务 ID 的方式。该变量（即 celery 应用程序）将 redis 代理和后端 url 设置为其属性的一部分。这工作正常。app from celery i...

为了发出长时间运行的任务，例如在后台作业中删除帖子，我决定根据 Flask 官方教程将 Celery 与 Flask 集成为新的初学者 Background Tasks with Celery 但是出...

在我的应用程序中，我有 rabbitmq 作为消息代理和芹菜来管理 BE 中的任务。 尝试运行任何芹菜@shared_task出现此错误时： kombu.exceptions.Operationa...

我正在使用以下参数运行我的工作线程，Redis 作为我的芹菜代理--without-gossip --without-mingle --without-heartbeat 我可以看到我的 redis...

我目前有一个系统，可以使用 Celery 在耳语 AI 模型上启动任务。但是，现有设置涉及在每个任务中加载模型，这是次优的，因为重复加载过程会消耗大量时间。不幸的是，我无法承受持续加载模型的费用，因为...