celery异步使用和启动方法

 1.创建celery文件夹

 2.新建main.py和config.py文件

 3.在main.py设置celery配置文件:如下

  from celery import Celery

  import os

  导入应用设置文件(django)

  

if not os.getenv('DJANGO_SETTINGS_MODULE'):
os.environ['DJANGO_SETTINGS_MODULE'] = '配置文件名'

实例化文件
app = Celery('随便起名字')
导入celery配置文件
app.config_from_object('config配置文件')
导入要执行的任务文件夹,会自动在文件下寻找tasks.py文件,并且执行文件里面的装饰器@app.tasks(name='函数名')装饰的函数.
app.autodiscover_tasks('要执行的任务文件夹')

启动方法:

  celery -A celery_tasks.main worker -l info  可以查看信息

原文地址:https://www.cnblogs.com/wangdongpython/p/10825920.html