add set redis

trans2es/management/commands/trans2es_data2es_parallel.py

@@ -65,8 +65,8 @@ class SyncDataToRedis(object):
                 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)
+                                                                              similarity__gt=0.3).order_by(
+                    "-similarity")
 
                 item_list = list()
                 for item in similar_result_items:
@@ -111,7 +111,6 @@ class Command(BaseCommand):
 
             slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size)
 
-
             for chunk in slicer.chunks():
                 job = Job(
                     sub_index_name=type_name,

trans2es/models/face_user_contrast_similar.py

@@ -10,6 +10,7 @@ manager = lambda: models.Manager().db_manager(using='face')
 
 class FaceUserContrastSimilar(models.Model):
     class Meta:
+        app_label = 'face'
         verbose_name = u"用户脸相似表"
         db_table = "face_user_contrast_similar"
 
@@ -22,3 +23,4 @@ class FaceUserContrastSimilar(models.Model):
     similarity = models.FloatField(verbose_name=u'相似度', default=0)
     create_time = models.DateTimeField(verbose_name=u'创建时间', default=datetime.datetime.fromtimestamp(0))
     update_time = models.DateTimeField(verbose_name=u'更新时间', default=datetime.datetime.fromtimestamp(0))
+