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

"""

测试celery

终端运行：celery -A python_celery:app worker -l INFO

"""

import time

from celery import Celery

broker = "redis://localhost:6379/10" # 用redis做broker，中间件

backend = "redis://localhost:6379/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