add

injection/data_sync/tasks.py

@@ -11,6 +11,8 @@ import traceback
 from libs.cache import redis_client
 from trans2es.models.face_user_contrast_similar import FaceUserContrastSimilar
 import json
+from celery.utils.log import get_task_logger
+logger = get_task_logger(__name__)
 
 
 @shared_task
@@ -34,6 +36,9 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False):
 @shared_task
 def sync_face_similar_data_to_redis():
     try:
+        logger.info(('Executing task id {0.id}, args: {0.args!r}'
+                     'kwargs: {0.kwargs!r}').format(self.request))
+
         result_items = FaceUserContrastSimilar.objects.filter(is_online=True, is_deleted=False).distinct().values(
             "participant_user_id").values_list("participant_user_id", flat=True)
 

physical/settings.py

@@ -53,7 +53,7 @@ CELERY_QUEUES = {
 
 CELERY_BROKER_URL = "redis://127.0.0.1:6379/8"
 CELERY_TIMEZONE = 'Asia/Shanghai'
-CELERY_ROUTES = ['physical.celery_task_router.CeleryTaskRouter']
+# CELERY_ROUTES = ['physical.celery_task_router.CeleryTaskRouter']
 
 
 INSTALLED_APPS = (