指定worker数为1，完成200个任务后重启worker

Author: caitinggui

configs/celery.py

@@ -1,26 +1,30 @@
+# coding: utf-8
 from __future__ import absolute_import
 
 import os
-import logging
 
 from celery import Celery
 from django.conf import settings
 
-# set the default Django settings module for the 'celery' program.  
-os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'configs.settings')  
-app = Celery('configs')  
+# set the default Django settings module for the 'celery' program.
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'configs.settings')
+app = Celery('configs')
 
-# Using a string here means the worker will not have to  
-# pickle the object when using Windows.  
-app.config_from_object('django.conf:settings', namespace='CELERY')  
-app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)  
+# Using a string here means the worker will not have to
+# pickle the object when using Windows.
+app.config_from_object('django.conf:settings', namespace='CELERY')
+app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
 
 app.conf.update(
     CELERY_TASK_SERIALIZER='json',
     CELERY_ACCEPT_CONTENT=['json'],
     CELERY_RESULT_SERIALIZER='json',
+    CELERYD_CONCURRENCY=1,
+    CELERY_WORKER_MAX_TASKS_PER_CHILD=200,  # 完成一定数量后重启该worker
+    CELERY_TIMEZONE='Asia/Shanghai'
 )
 
-@app.task(bind=True)  
-def debug_task(self):  
-    print('Request: {0!r}'.format(self.request))  
+
+@app.task(bind=True)
+def debug_task(self):
+    print('Request: {0!r}'.format(self.request))