- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
我已经配置了 celery 和后端:
cleryapp = Celery(
'tasks_app', brocker='amqp://guest@localhost//',
backend='db+postgresql://guest@localhost:5432'
)
当我启动 worker 时,'results' 似乎被禁用,但我在这里读到另一个问题,这不是问题所在。
数据库正在正确获取所有数据,但是
result = AsyncResult(task_id)
加注
AttributeError: 'DisabledBackend' object has no attribute '_get_task_meta_for'
最佳答案
我找到了一种更方便的方法来做到这一点。
result = celery.AsyncResult(task_id)
celery
是应用程序的 Celery 实例,而不是 celery 模块。
关于python - celery 结果后端。 DisabledBackend 对象没有属性 _get_task_meta_for,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24309035/
我收到错误消息“'DisabledBackend' 对象没有属性 '_get_task_meta_for'”../ 这是 django settings.py # celery settings CE
我正在尝试在 WSL 中安装 airflow(分布式模式),我安装了 Airflow 网络服务器、Airflow Scheduler、Airflow Worker、Celery (3.1) 和 Rab
如果超时(如果任务未在给定时间内完成),我正在尝试从 celery 任务中读取元信息。我有 3 个 celery worker 。当我连续对 3 个工作人员执行任务时,我的超时逻辑(从 redis 后
我已经配置了 celery 和后端: cleryapp = Celery( 'tasks_app', brocker='amqp://guest@localhost//', backe
我已经使用 Celery 一段时间了,在生产环境中,我使用 RabbitMQ 作为代理,使用 Redis 作为 K8s 集群中的后端,到目前为止没有任何问题。在本地,我运行一个包含一些服务(Flask
我想研究celery项目,但是不知道哪里出错了。“tasks.py”文件: # -*- coding: utf-8 -*- from celery import Celery app = Celery
我正在运行 First Steps with Celery Tutorial . 我们定义以下任务: from celery import Celery app = Celery('tasks', b
我是一名优秀的程序员,十分优秀!