经常用python开发web应用时，会涉及到定时任务的脚本，以前用linux自带的crontab来操作，但是感觉不太接地气，后来发现用celery+django 可以方便的实现！

安装软件环境如下：

python 2.7.5

Django==1.8.2

celery==3.1.18

celery-with-redis==3.0

django-celery==3.1.16

MySQL-python==1.2.3

supervisor==3.1.3

使用pip方式安装完以上软件，并且默认系统已经安装了redis和mysql服务器！


一 首先创建project：

django-admin.py createproject picha

然后创建名称为demo的app：

django-admin.py startapp demo

项目的目录结构为：


二 下面在settings文件中配置celery相关的配置：

#CELERYSTUFFimportdjcelerydjcelery.setup_loader()BROKER_URL='redis://localhost:6379'CELERYBEAT_SCHEDULER='djcelery.schedulers.DatabaseScheduler'#定时任务CELERY_RESULT_BACKEND='djcelery.backends.database:DatabaseBackend'CELERY_RESULT_BACKEND='redis://localhost:6379'CELERY_ACCEPT_CONTENT=['application/json']CELERY_TASK_SERIALIZER='json'CELERY_RESULT_SERIALIZER='json'CELERY_TIMEZONE='Asia/Shanghai'

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


在和settings.py同级目录中编辑文件 |__init__.py

#!/usr/bin/envpython#coding:utf-8from__future__importabsolute_import#Thiswillmakesuretheappisalwaysimportedwhen#Djangostartssothatshared_taskwillusethisapp.from.celeryimportappascelery_app


然后修改市区：

TIME_ZONE='Asia/Shanghai'

市区不对，计划任务是不会按时间执行的！


另外，我们还需要在创建一个celery.py文件，他会自动发现我们app下面的task！

#!/usr/bin/envpython#coding:utf-8from__future__importabsolute_importimportosfromceleryimportCeleryfromdjango.confimportsettings#setthedefaultDjangosettingsmoduleforthe'celery'program.os.environ.setdefault('DJANGO_SETTINGS_MODULE','picha.settings')app=Celery('picha')#Usingastringheremeanstheworkerwillnothaveto#pickletheobjectwhenusingWindows.app.config_from_object('django.conf:settings')app.autodiscover_tasks(lambda:settings.INSTALLED_APPS)@app.task(bind=True)defdebug_task(self):print('Request:{0!r}'.format(self.request))


现在我们在demo的app下面创建测试用的task！

from__future__importabsolute_importfromceleryimportshared_task,task@shared_task()defadd(x,y):#returnx+yprintx+y@shared_task()defmul(x,y):print"%d*%d=%d"%(x,y,x*y)returnx*y@shared_task()defsub(x,y):print"%d-%d=%d"%(x,y,x-y)returnx-y@task(ignore_result=True,max_retries=1,default_retry_delay=10)defjust_print():print"Printfromcelerytask"


到这里，django和celery部分已经安装完成！


三 我现在开始配置supervisor，用来启动相关celery程序：

1）初始化supervisor配置文件！

echo_supervisord_conf > /etc/supervisord.conf


2）然后在supervisord.conf文件末尾添加如下配置：

[program:djangoproject.celeryd]command=/usr/local/pyenv/shims/python/usr/local/coding/pythoner/picha/manage.pyceleryd--concurrency=1user=rootnumprocs=1directory=/usr/local/coding/pythoner/pichastdout_logfile=/var/log/celery_worker.logstderr_logfile=/var/log/celery_worker.logautostart=trueautorestart=truestartsecs=10stopwaitsecs=120priority=998[program:djangoproject.celerybeat]command=/usr/local/pyenv/shims/python/usr/local/coding/pythoner/picha/manage.pycelerybeat--schedule=/tmp/celerybeat-schedule--pidfile=/tmp/django_celerybeat.pid--loglevel=INFOuser=rootnumprocs=1directory=/usr/local/coding/pythoner/pichastdout_logfile=/var/log/celery_beat.logstderr_logfile=/var/log/celery_beat.logautostart=trueautorestart=truestartsecs=10stopwaitsecs=120priority=998[program:djangoproject.celerycam]command=/usr/local/pyenv/shims/python/usr/local/coding/pythoner/picha/manage.pycelerycam--frequency=10.0user=rootnumprocs=1directory=/usr/local/coding/pythoner/pichastdout_logfile=/var/log/celerycam.logstderr_logfile=/var/log/celerycam.logautostart=trueautorestart=truestartsecs=10stopwaitsecs=120priority=998


四 现在我们需要把celery相关的库文件同步到mysql中，我们使用命令：

pythonmanage.pysyncdb

然后创建superuser

django-admin manage.py createsuperuser


启动supervisor：

supervisord -d

查看服务是否启动成功，使用命令supervisorctl status


djangoproject.celerybeat RUNNING pid 3061, uptime 1:03:27

djangoproject.celerycam RUNNING pid 3063, uptime 1:03:27

djangoproject.celeryd RUNNING pid 3062, uptime 1:03:27




然后我们进入到django-admin后台，

现在我们启动django：

python manage.py runserver 0.0.0.0:8008


进入后台后，点击“Periodic tasks”：

可以看到写在tasks.py下面的方法，在下拉菜单中都出现了，我们只用选择对应的时间即可！

现在，我们开始选择计划任务的时间：

我们创建一个定时任务，没10s，print一个数值，放在在日志文件中查看：

我们查看日志文件：

符合我们在web后台的设置！


我们在设置一个加法运算，每隔15s运行一次，而且我们可以在web平台后端动态的修改所传的参数，

第一次，我们传入参数9和5，结果应该为14，我们看下设置和日志：

我再看下日志：


然后我们在web后台修改传入参数为10和7，不重启服务，计算的结果动态变化为17！

我们发现，结果数据已经动态变化！


我们如果启动了 supervisor脚本中的：/usr/local/coding/pythoner/picha/manage.py celerycam --frequency=10.0

就可以在admin后台查看 woker是不是在线：

celery-django相关的配置就完成了！


PS：配置过程中计划任务的结果只能日志中查看，不知道怎么在admin的后台中显示，如果大家知道，可以告诉我，3Q！