celery包结构
project
├── celery_task # celery包 这个包可以放在任意位置
│ ├── __init__.py # 包文件
│ ├── celery.py # celery连接和配置相关文件，且名字必须叫celery.py
│ └── tasks.py # 所有任务函数
│
├── add_task.py # 添加任务 （这两个和上面的包没有必然联系）
└── get_result.py # 获取结果（这两个和上面的包没有必然联系）
1、创建celery_task 包，包内部有celery.py和一堆task-----》 ['celery_task.home_task','celery_task.user_task'] 这个是celery_task下面的文件，写一个文件就注册
2、celery.py
3、每个task写自己相关任务
4、启动worker
celery -A celery_task（编写任务,必须用app.task 装饰，才变成了celery的任务） worker -l info -P eventlet
5、提交任务，需要提交任务的写delay
from celery_task.home_task import add
res=add.delay(3,4)
print(res)
6、查看结果
