标签:col app res port 异步 work rom cas cal
我们的项目在使用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,到数据库查询对应的结果
跟德国技术咨询可关注:gzitcast
标签:col app res port 异步 work rom cas cal
原文地址:https://www.cnblogs.com/heimaguangzhou/p/11670685.html