django+celery配置(定时任务+循环任务)

下面介绍一下django+celery的配置做定时任务

1.首先介绍一下环境和版本

   python==2.7

　django == 1.8.1

   celery == 3.1.23

   django-celery == 3.1.17

2.celery的安装

  sudo pip install celery==3.1.23

  sudo pip install django-celery==3.1.17

3.新建一个项目

　　(1)django-admin startproject django_celery_demo

      (2)cd django_celery_demo

      (3)django-admin startapp appdemo

4.修改项目配置(django_celery_demo/django_celery_demo/settings.py)

    (1)第一行引入absolute_import

from __future__ import absolute_import

    (2)INSTALLED_APPS添加'djcelery','appdemo'

INSTALLED_APPS = ( 'django.contrib.admin', 'django.contrib.auth', 'django.contrib.contenttypes', 'django.contrib.sessions', 'django.contrib.messages', 'django.contrib.staticfiles', 'djcelery', 'appdemo', )

    (3)在setting.py最下方加入

import djcelery from celery.schedules import crontab djcelery.setup_loader() BROKER_URL = 'redis://:dahai123@192.168.5.60:6380/6' # BROKER_URL = 'redis://:密码@主机地址:端口号/数据库号' from datetime import timedelta CELERYBEAT_SCHEDULE = { 'add-every-3-seconds': { 'task': 'appdemo.tasks.test_celery', # 'schedule': crontab(minute=u'40', hour=u'17',), 'schedule': timedelta(seconds=3), 'args': (16, 16) }, }

5.创建django_celery_demo/django_celery_demo/celery.py,文件内容如下

from __future__ import absolute_import import os from celery import Celery, platforms # set the default Django settings module for the 'celery' program. os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'django_celery_demo.settings') from django.conf import settings # noqa app = Celery('django_celery_demo') platforms.C_FORCE_ROOT = True # Using a string here means the worker will not have to # pickle the object when using Windows. app.config_from_object('django.conf:settings') app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) @app.task(bind=True) def debug_task(self): print('Request: {0!r}'.format(self.request))

 

6.在django_celery_demo/django_celery_demo/__init__.py引入

from __future__ import absolute_import from .celery import app as celery_app

7.创建django_celery_demo/appdemo/tasks.py文件,内容如下

 

from __future__ import absolute_import import logging from celery import task from celery.utils.log import get_task_logger from celery.schedules import crontab @task def test_celery(x, y): logger = get_task_logger(__name__) logger.info('func start ----------------->') logger.info('application:%s', "TEST_APP") logger.info('func end -------------------->') print x + y return x + y @task def test_multiply(x, y): logger = get_task_logger(__name__) logger.info('func start ----------------->') logger.info('application:%s', "TEST_APP") logger.info('func end -------------------->') print x * y return x * y

 

 

 

8.开始测试

　　python manage.py makemigrations  # 同步数据库,首次使用

　　python  manage.py celery -A django_celery_demo  worker -B    # django_celery_demo为celery和setting所在文件夹名

　　

9.上面时循环任务,还可以做定时任务:

django_celery_demo/django_celery_demo/settings.py

CELERYBEAT_SCHEDULE = { 'add-every-3-seconds': { 'task': 'appdemo.tasks.test_celery', # 'schedule': crontab(minute=u'40', hour=u'17',), 'schedule': timedelta(seconds=3), 'args': (16, 17) }, 'timing': { 'task': 'appdemo.tasks.test_multiply', 'schedule': crontab(minute=u'28', hour=u'11',), # 'schedule': timedelta(seconds=3), 'args': (2, 3) }, }

不要忘了把时间改为北京时间,我在上海就改成了上海

TIME_ZONE = 'Asia/Shanghai' USE_I18N = True USE_L10N = True USE_TZ = False

定时在11:28开启的任务执行

转载于:https://www.cnblogs.com/wangmin0216/p/6567539.html