使用celery的backend异步获取结果

惯例先贴出相关参考的文档：

http://docs.celeryproject.org/en/stable/getting-started/next-steps.html

http://docs.celeryproject.org/en/stable/userguide/tasks.html#task-result-backends

这篇紧接上篇。

其实我们一般对这种异步任务需求是可能需要回调的。比如说我现在有一个支付的异步任务发送到了队列。

生产者不需要等待，在发送到队列之后就告诉用户已经支付成功了或者说正在支付稍后再来查看状态。

这个时候celery的worker获取到这个任务之后开始处理，等一会儿他处理完毕之后可能需要将这个处理完毕的结果返回给发送给他的生产者。

那么问题来了，如何告知生产者？因为生产者生产完消息之后就结束了。

那么这个时候就使用到了backend这个参数了：

当我们像指明broker一样指明了backend之后，当worker运行完结果之后就会把他返回给生产者的唯一id作为键，将结果作为值传递给你设置的worker(backend测试环境为redis).这个时候你无论在什么时候只要拿着这个值去redis里面查找到结果就行了。比如你在执行一个任务，你可以设置一个周期性轮询，去查看这个结果是否已经被生产出来，如果生产出来便取到该值做相应的操作即可。下面为具体操作实例：

先贴出一个我统一使用的配置文件

# file_name=init_celery.py# coding: utf-8
from celery import CeleryBROKER_URL = 'redis://:password@localhost:6379/0'
BACKEND_URL = 'redis://:password@localhost:6379/1'# Add tasks here
CELERY_IMPORTS = ('try',
)celery = Celery('celery',broker=BROKER_URL,backend=BACKEND_URL,include=CELERY_IMPORTS,)celery.conf.update(CELERY_ACKS_LATE=True,CELERY_ACCEPT_CONTENT=['pickle', 'json'],CELERYD_FORCE_EXECV=True,CELERYD_MAX_TASKS_PER_CHILD=500,BROKER_HEARTBEAT=0,
)

然后是celery任何函数

from init_celery import celery@celery.task
def add(x, y):result = x + yprint resultreturn result

最后我们调用这个函数执行异步操作

from tasks import adddef notify(a, b):result = add.apply_async((a, b), queue='laplace')return resultif __name__ == '__main__':haha = notify(6, 7)print haha.statusprint haha.idprint haha.get(timeout=1)

这里注意我使用了task.apply_async这个函数。其实效果根task.delay差不多只是可以指定更多的参数。这里我指定了使用的队列为laplace队列，所以对应的监听的队列也必须使用参数-Q监听对应的队列，才能获得结果。

这里返回的result其实就是一个唯一的<class 'celery.result.AsyncResult'>对象。

我们可以对这个对象查看他的状态，id 以及使用get去得到他的具体值。

合理的使用这个get方法就可以取得woker处理之后的值，同时在redis可以清楚的看到，worker处理之后自动帮你在redis里面存储了

这么介绍之后对于backend是不是已经一目了然了呢？其实我在进行之类操作的时候还踩了一些配置文件方面的坑，

所以一定要仔细的参考官方文档进行操作。和查看更多你需要用到的功能和参数。

使用celery的backend异步获取结果相关推荐

Celery - 一个懂得异步任务 , 定时任务 , 周期任务的芹菜
1.什么是Celery? Celery 是芹菜 Celery 是基于Python实现的模块, 用于执行异步定时周期任务的其结构的组成是由 1.用户任务 app 2.管道 broker ...
Celery+Rabbitmq实现异步任务
Celery+Rabbitmq实现异步任务一. 安装celery,再安装rabbitmq或redis pip install celery rabbitmq和redis安装其中一个就可以了,cele ...
异步获取邮件推送结果
邮件推送服务提供了事件通知功能(可在其控制台上打开异步通知功能),支持将邮件推送的结果以消息的方式异步通知给用户.用户可以通过创建事件通知的规则,来指定在邮件推送过程中触发不同的事件时,将邮件推送的结 ...
Vue：echarts画图实战，异步获取数据在Vue上使用echarts进行画图
Vue:echarts画图实战,异步获取数据在Vue上使用echarts进行画图一.效果图二.资源主题编辑器 ECharts 教程实现代码------想要进行实战的同学可以研究以下代码,下面的 ...
node 创建静态web服务器（下）（处理异步获取数据的两种方式）
接上一章. 上一章我们说创建的静态web服务器只能识别html,css,js文件,功能较为单一,且图片格式为text/html,这是不合理的. 本章,我们将解决该问题. 这里,我们先准备好一个json ...
vue 父组件获取接口值传到子组件_vue父组件异步获取数据传给子组件的方法
但是现在问题是父组件的数据是异步获取的,而子组件一开始就会渲染,如果此时没有传入数据,而子组件又要用到数据中的length属性时就会报错: 怎么办呢?最简单的办法就是让子组件条件渲染,当有数据的时候才 ...
jQuery中的ajax、jquery中ajax全局事件、load实现页面无刷新局部加载、ajax跨域请求jsonp、利用formData对象向服务端异步发送二进制数据，表单序列化（异步获取表单内容）
jQuery中使用ajax: 在jQuery中使用ajax首先需要引入jQuery包,其引入方式可以采用网络资源,也可以下载包到项目文件中,这里推荐下载包到文件中:市面上有多个版本的jQuery库,这 ...
利用Future异步获取多线程的返回结果
Future接口是Java标准API的一部分,在java.util.concurrent包中.Future接口是Java线程Future模式的实现,可以来进行异步计算. 有了Future就可以进行三段 ...
easyui panel异步获取后台数据在前台显示
我在使用easyui的时候,想做一个向下图所示的效果,这个panel的样式已经做好了,想从后台异步获取json数据,然后填入到文本框中,不知道哪位大神能给点指导?万分感谢! 放入表单中,使用form对 ...

使用celery的backend异步获取结果

使用celery的backend异步获取结果相关推荐

最新文章

热门文章