最小工作进程示例

这里给出一个最小的工作进程作为示例。

# 文件名：tasks.py
from celery import Celery


app = Celery('tasks', broker='amqp://guest@localhost//')

@app.task
def add(x, y):
	return x + y

这个最小示例中从celery模块中引入了Celery类，并使用它建立了任务。这个最小示例可以使用以下命令启动：celery -A tasks worker --loglevel=info。

之后可以在其他脚本中使用以下代码调用：

from tasks import add


add.deley(1, 1)