celery.py 778 B

12345678910111213
  1. from __future__ import absolute_import,unicode_literals
  2. import os
  3. from celery import Celery
  4. from django.conf import settings
  5. os.environ.setdefault("DJANGO_SETTINGS_MODULE", "yfwlw_pro.settings") # 设置celery可以在命令行中使用
  6. app = Celery('yfwlw_pro') # 创建app实例
  7. # app = Celery('tcelery', backend='redis://localhost:6379/0', broker='redis://localhost:6379/0')
  8. app.conf.CELERY_IGNORE_RESULT = False # 结果不忽略
  9. # app.conf.CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' #结果保存在redis中
  10. app.config_from_object('django.conf:settings') # 从文件中加载实例
  11. app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) # 自动加载tasks,注意:他会去app下面查找tasks.py文件,所以我们必须将task放在tasks.py文件中