python_celery.py

# _*_ 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