# _*_ coding: utf-8 _*_

"""
测试celery
运行：celery -A celery1:app worker -l INFO
"""

import time
from celery import Celery

broker = 'redis://152.136.149.221:9002/10'   # 用redis做broker，中间件
backend = 'redis://152.136.149.221:9002/11'    # 用redis做broken，用来保存结果

app = Celery('tasks',broker=broker,backend=backend)

@app.task
def add(x, y):
    print(time.time(), x, y)
    time.sleep(3)
    print(time.time(), x, y, "--")
    return x + y