Celery 初次使用

我们首先创建一个app文件夹,在文件夹下创建一个tasks.py的文件

  1. from celery import Celery
  2. app = Celery('tasks',broker='amqp://guest@localhost//')
  3. @app.task
  4. def add(x,y):
  5.     return x + y

第一