@@ -0,0 +1,724 @@
+from __future__ import absolute_import, unicode_literals%0Aimport os%0Afrom celery import Celery%0A%0A# set the default Django settings module for the 'celery' program.%0Aos.environ.setdefault('DJANGO_SETTINGS_MODULE', 'iotendpoints.settings')%0A%0Aapp = Celery('iotendpoints')%0A%0A# Using a string here means the worker don't have to serialize%0A# the configuration object to child processes.%0A# - namespace='CELERY' means all celery-related configuration keys%0A#   should have a %60CELERY_%60 prefix.%0Aapp.config_from_object('django.conf:settings', namespace='CELERY')%0A%0A# Load task modules from all registered Django app configs.%0Aapp.autodiscover_tasks()%0A%0A%0A@app.task(bind=True)%0Adef debug_task(self):%0A    print('Request: %7B0!r%7D'.format(self.request))

Add celery