创建任务
# 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)
本文标题:Celery初步
本文链接:https://www.haomeiwen.com/subject/gbfmmxtx.html
网友评论