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