黑马程序员技术交流社区

标题: 【广州python】使用celery的backend异步获取结果 [打印本页]

作者: dingliu    时间: 2018-9-27 13:16
标题: 【广州python】使用celery的backend异步获取结果
本帖最后由 dingliu 于 2018-10-23 10:32 编辑

我们的项目在使用celery异步任务的时候,并没有告诉大家如何去查询我们异步任务的执行结果,这里小编简单跟大家聊一聊,提供一下思路

如果需要查看异步任务的调用结果,就需要使用到了backend这个参数了:当我们像指明broker一样指明了backend之后,当worker执行完任务,会返回task唯一id作为键,将结果作为值传递给backend,这个时候你可以拿着这个id去redis里面查找结果。

以下为案例:

# 配置
from celery import Celery
BROKER_URL = 'redis://:password@localhost:6379/0'
BACKEND_URL = 'redis://:password@localhost:6379/1'


# 创建一个Celery对象celery_app = Celery('celery_tasks')
# 加载配置
celery_app.config_from_object('celery_tasks.config')

调用任务函数
@celery.task
def add(x, y):
    result = x + y
    print result
    return result

调用函数执行异步任务
result = add.delay(a, b)


result为一个异步任务对象,根据对象获取id,到数据库查询对应的结果
扫码关注黑马视频库公众号,免费获取黑马全学科视频教程







欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2