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、查看结果