add

injection/data_sync/tasks.py

@@ -4,7 +4,7 @@ from celery import shared_task
 from django.conf import settings
 from django.core import serializers
 from trans2es.type_info import get_type_info_map
-#from rpc.all import get_rpc_remote_invoker
+# from rpc.all import get_rpc_remote_invoker
 from libs.es import ESPerform
 import logging
 import traceback
@@ -12,6 +12,7 @@ from libs.cache import redis_client
 from trans2es.models.face_user_contrast_similar import FaceUserContrastSimilar
 import json
 
+
 @shared_task
 def write_to_es(es_type, pk_list, use_batch_query_set=False):
     try:
@@ -33,7 +34,8 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False):
 @shared_task
 def sync_face_similar_data_to_redis():
     try:
-        result_items = FaceUserContrastSimilar.objects.filter(is_online=True,is_deleted=False).distinct().values("participant_user_id").values_list("participant_user_id",flat=True)
+        result_items = FaceUserContrastSimilar.objects.filter(is_online=True, is_deleted=False).distinct().values(
+            "participant_user_id").values_list("participant_user_id", flat=True)
 
         logging.info("duan add,begin sync_face_similar_data_to_redis!")
 
@@ -41,19 +43,21 @@ def sync_face_similar_data_to_redis():
         for participant_user_id in result_items:
 
             redis_key = redis_key_prefix + str(participant_user_id)
-            similar_result_items = FaceUserContrastSimilar.objects.filter(is_online=True,is_deleted=False,participant_user_id=participant_user_id,similarity__gt=0.4).order_by("-similarity").limit(100)
+            similar_result_items = FaceUserContrastSimilar.objects.filter(is_online=True, is_deleted=False,
+                                                                          participant_user_id=participant_user_id,
+                                                                          similarity__gt=0.3).order_by(
+                "-similarity")
 
             item_list = list()
             for item in similar_result_items:
                 item_list.append(
                     {
-                        "contrast_user_id":item.contrast_user_id,
-                        "similarity":item.similarity
+                        "contrast_user_id": item.contrast_user_id,
+                        "similarity": item.similarity
                     }
                 )
-            redis_client.set(redis_key,json.dumps(item_list))
+            redis_client.set(redis_key, json.dumps(item_list))
 
             logging.info("duan add,participant_user_id:%d set data done!" % participant_user_id)
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
-

injection/data_sync/views.py

 from django.shortcuts import render
 
 # Create your views here.
+
+
+from injection.data_sync.tasks import sync_face_similar_data_to_redis
+
+
+def post(request):
+    result = sync_face_similar_data_to_redis()

physical/__init__.py

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

physical/celery.py

@@ -22,3 +22,23 @@ app.conf.broker_url = settings.CELERY_BROKER_URL
 @app.task(bind=True)
 def debug_task(self):
     print('Request: {0!r}'.format(self.request))
+
+
+
+from celery.schedules import crontab
+
+app.conf.update(
+    CELERYBEAT_SCHEDULE = {
+        'sum-task': {
+            'task': 'deploy.tasks.add',
+            'schedule':  crontab(hour=1),
+            'args': (5, 6)
+        },
+        'send-report': {
+            'task': 'deploy.tasks.report',
+            'schedule': crontab(hour=4, minute=30, day_of_week=1),
+        }
+    }
+)
+
+