Sunbelt Computer Software

PL/B Language Development and Support

LearnPython/python_celery.py at master · jinchener/LearnPython · GitHub

23 lines (16 loc) · 476 Bytes

# _*_ coding: utf-8 _*_
终端运行：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)
def add(x, y):
    print(time.time(), x, y)
    time.sleep(3)
    print(time.time(), x, y, "--")
    return x + y