Canonical Celery 单文件 hello world

Question

我似乎无法在网上的任何地方找到一个可以使用 Celery 和 Python 从头到尾运行的单个文件来演示它，所以我尝试制作一个。由于某种原因，这不起作用，我是芹菜的新手。在test_celery.py我添加了以下内容：

from celery import Celery
import time

app = Celery(
    'test_celery'
    ,broker= 'redis://localhost/0',
    backend='redis://localhost/1'
)

@app.task
def add(x, y):
    time.sleep(2)
    return x + y

if __name__ == '__main__':
    result = add.delay(4, 4)
    print( result.get() )

然后我在本地主机上运行 redis 服务器并在控制台输入：

celery -A test_celery worker --loglevel=info

所以，现在工作人员正在倾听，我试着运行python test_celery.py，认为我应该在控制台输出中看到我的精彩 8。在工作控制台的日志中，我看到[2015-01-02 16:53:08,807: INFO/MainProcess] Task test_celery.add[2c6b19c0-3a3f-45d2-8024-64e112fa3419] succeeded in 1.9970000002067536s: 8哪个符合预期，但对result.get主程序控制台的调用挂起。

我一定在这里遗漏了一些基本的东西，如果有人能帮忙那就太好了。

Answer 1

解决方案是简单地通过调用设置结果后端，app.conf.update而不是在Celery对象的构造函数中。

我在 Celery GitHub 页面上的这篇帖子中找到了这个问题的解决方案。这仍然是一个悬而未决的问题（目前）

解决方案

from celery import Celery
import time

app = Celery(
    'test_celery'
    ,broker= 'redis://localhost/0'
)

app.conf.update(
    CELERY_RESULT_BACKEND = 'redis://localhost/1'
)

@app.task
def add(x, y):
    time.sleep(2)
    return x + y

if __name__ == '__main__':
    result = add.delay(4, 4)
    print( result.get() )

按预期工作。