add

injection/data_sync/views.py

 from django.shortcuts import render
 
 # Create your views here.
+
+from injection.data_sync import tasks
+from django.http import JsonResponse
+
+
+def index(request,*args,**kwargs):
+    res=tasks.add.delay(1,3)
+    #任务逻辑
+    return JsonResponse({'status':'successful','task_id':res.task_id})

physical/__init__.py

@@ -4,4 +4,4 @@ import pymysql
 from _celery import app as celery_app
 
 pymysql.install_as_MySQLdb()
-#__all__ = ('celery_app',)
+__all__ = ('celery_app',)

physical/celery_task_router.py

 # coding=utf-8                                                                           
-from __future__ import unicode_literals, print_function, absolute_import                 
-                                                                                         
-import itertools                                                                         
-                                                                                         
-from django.conf import settings                                                         
+from __future__ import unicode_literals, print_function, absolute_import
+
+import itertools
+
+from django.conf import settings
 import logging
 
+
 class CeleryTaskRouter(object):
     queue_task_map = {
-        "tapir-alpha":[
+        "tapir-alpha": [
             'injection.data_sync.tasks.write_to_es',
         ]
     }
@@ -30,4 +31,4 @@ class CeleryTaskRouter(object):
 
         logging.info("duan add,task is:%s" % str(task))
         queue_name_or_none = self.task_queue_map.get(task)
-        return queue_name_or_none
\ No newline at end of file
+        return queue_name_or_none

physical/settings.py

@@ -56,6 +56,12 @@ BROKER_URL = "redis://127.0.0.1:6379/8"
 CELERY_BROKER_URL = "redis://127.0.0.1:6379/8"
 CELERY_TIMEZONE = 'Asia/Shanghai'
 CELERY_ROUTES = ['physical.celery_task_router.CeleryTaskRouter']
+CELERY_RESULT_SERIALIZER = 'json' # 结果序列化方案
+
+
+CELERY_RESULT_BACKEND = 'redis://10.1.210.69:6379/0' # BACKEND配置，这里使用redis
+
+
 
 INSTALLED_APPS = (
     'django.contrib.admin',