Celery异步分布式

Celery 概念

Celery是一个python开发的异步分布式任务调度模块。

Celery本身并不提供消息服务，使用第三方服务，也就是borker来传递任务，目前支持rebbimq，redis， 数据库等。

这里我们使用redis

连接url的格式为：

redis://:password@hostname:port/db_number

例如：

BROKER_URL = 'redis://localhost:6379/0'

安装celery

pip install celery

pip install redis

在服务器上安装redis服务器，并启动redis

第一个简单的例子：

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# Author :Alvin.xie
# @Time :2017-12-19 13:23
# @file :3.py

from celery import Celery
broker="redis://10.89.3.1:6379/5"
backend="redis://10.89.3.1:6379/6"
app = Celery("ling", broker=broker, backend=backend)

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

启动worker

#celery -A ling worker -l info

生产者

form ling import add

re = add.delay(10, 20)

print(re.result)  #获取结果

print(re.ready)  #是否处理

print(re.get(timeout=1))  #获取结果

print(re.status)  #是否处理