创建任务
# tasks.py
from celery import Celery
app = Celery('tasks', broker = 'redis://localhost:6379/0')
@app.task
def add(x, y)
return x + y
运行Celery职程服务器
celery -A tasks worker --loglevel=info
调用任务
from tasks import add
add.delay(4, 4)
# tasks.py
from celery import Celery
app = Celery('tasks', broker = 'redis://localhost:6379/0')
@app.task
def add(x, y)
return x + y
celery -A tasks worker --loglevel=info
from tasks import add
add.delay(4, 4)