add

injection/data_sync/views.py

@@ -5,8 +5,3 @@ from django.shortcuts import render
 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/settings.py

@@ -18,7 +18,6 @@ from celery.schedules import crontab
 # Build paths inside the project like this: os.path.join(BASE_DIR, ...)
 BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
 
-
 # Quick-start development settings - unsuitable for production
 # See https://docs.djangoproject.com/en/1.10/howto/deployment/checklist/
 
@@ -30,17 +29,17 @@ DEBUG = False
 
 ALLOWED_HOSTS = []
 
-
 # Application definition
-SENTRY_CELERY_ENDPOINT="http://60b0004c8884420f8067fb32fc3ed244:20f97fc73ffa4aad9735d0e6542a6d78@sentry.igengmei.com/140"
+SENTRY_CELERY_ENDPOINT = "http://60b0004c8884420f8067fb32fc3ed244:20f97fc73ffa4aad9735d0e6542a6d78@sentry.igengmei.com/140"
 BROKER_URL = "redis://127.0.0.1:6379/8"
 
 # CELERY_SEND_EVENTS = True
 # CELERY_SEND_TASK_SENT_EVENT = True
 #
-# CELERY_DEFAULT_EXCHANGE = 'celery'
-# CELERY_DEFAULT_EXCHANGE_TYPE = 'direct'
-# CELERY_DEFAULT_ROUTING_KEY = 'celery'
+CELERY_DEFAULT_EXCHANGE = 'celery'
+CELERY_DEFAULT_EXCHANGE_TYPE = 'direct'
+CELERY_DEFAULT_ROUTING_KEY = 'celery'
+CELERY_IMPORTS = ('injection.data_sync.tasks', )
 #
 # CELERY_QUEUES = {
 #     'celery': {
@@ -56,12 +55,7 @@ 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
-
-
+CELERY_RESULT_SERIALIZER = 'json'  # 结果序列化方案
 
 INSTALLED_APPS = (
     'django.contrib.admin',
@@ -70,8 +64,8 @@ INSTALLED_APPS = (
     'django.contrib.sessions',
     'django.contrib.messages',
     'django.contrib.staticfiles',
-	'trans2es',
-	'search',
+    'trans2es',
+    'search',
     'injection.data_sync',
 )
 
@@ -151,7 +145,7 @@ DATABASES = {
         'PASSWORD': 'Gengmei123',
         'HOST': 'rm-2ze5k2we69904787l.mysql.rds.aliyuncs.com',
         'PORT': '3306',
-        #'CONN_MAX_AGE': None,
+        # 'CONN_MAX_AGE': None,
         'OPTIONS': {
             "init_command": "SET foreign_key_checks = 0;",
             "charset": "utf8mb4",
@@ -160,13 +154,13 @@ DATABASES = {
 
 }
 ES_INFO_LIST = [
-        {
-            "host": "10.29.130.141",
-            "port": 9200
-        }
+    {
+        "host": "10.29.130.141",
+        "port": 9200
+    }
 ]
 
-ES_INDEX_PREFIX="gm-dbmw"
+ES_INDEX_PREFIX = "gm-dbmw"
 
 MIDDLEWARE_CLASSES = (
     'gm_tracer.middleware.TracerMiddleware',