celery 使用 Redis 但是 backend 中没有数据进去

代码如下:
from celery import Celery
import time
broker = 'redis://127.0.0.1:6379/5'
backend = 'redis://127.0.0.1:6379/6'

app = Celery('tasks', broker=broker, backend=backend)
@app.task
def add(x,y):
print("enter task")
return x+y

但是backend中数据进不去,导致,使用
result = add.delay(2,2)后
result.ready() 一致为False

讨论数量: 4

我想知道你是怎么执行的。就这点东西没办法判断你遇到的问题。顺便说一句论坛支持 Markdown

5个月前 评论

官方给的例子是要写在文件中,然后在命令行执行。

celery -A tasks worker --loglevel=info

这里边的 tasks 就是你写的 celery 任务文件名。

5个月前 评论

已經解決
將redis升級到了3.2.0的版本,celery4.1.1的版本,
之前的celery-django-results1.0.4 和celery 3.1.17的版本不相容,不知道是不是這個原因,還沒進行錯誤重現

5个月前 评论

我现在也遇到一样的问题,不过我跟贴主不同的是,我是直接用的celery,没有django等web项目中。celery和redis版本都是最新的

3个月前 评论

请勿发布不友善或者负能量的内容。与人为善,比聪明更重要!