modify

trans2es/management/commands/trans2es_data2es_parallel.py

@@ -27,6 +27,7 @@ from trans2es.models.group import Group
 from trans2es.models.topic import Topic,ActionSumAboutTopic
 from search.utils.common import *
 from linucb.views.collect_data import CollectData
+from injection.data_sync.tasks import sync_user_similar_score
 
 class Job(object):
     __es = None
@@ -207,5 +208,8 @@ class Command(BaseCommand):
             if len(options["sync_type"]) and options["sync_type"]=="linucb":
                 collect_obj = CollectData()
                 collect_obj.consume_data_from_kafka()
+
+            if len(options["sync_type"]) and options["sync_type"]=="similar":
+                sync_user_similar_score()
         except:
             logging.error("catch exception,err_msg:%s" % traceback.format_exc())