python celery

先简单的了解一下celery

celery是一个异步任务调度工具,非常简单,灵活可靠,处理大量消息的分布式系统。它是根据AMQP协议(AMQP协议是应用层协议的开放标准,专门用来处理消息队列的为消息的中间件设计的)来处理一些耗时耗资源的事情

只有文字怕大家理解的费劲,所以这里还是需要简单的解释一下。比如说一个购物网站用户生产了订单(生产者)生成后他要把订单id之类的放进一个消息队列里,你可以用redis存储这个订单。那么要完成这个订单 消费者就要从队列里拿去订单的信息。进行结算之类的。

exchanges可以看作是分配生产者生产的信息应该去放在哪个queues(消息队列里)这里的queues可以是redis数据库这样的容器。而workworker就是消费者 它要主动去queues队列里面去拿生产者给信息进行处理

python celery

 

运用的场景实例:celery一般用来处理耗时的任务,比如发短信邮件,第三方支付需要实时抓取支付状态,消息推送等