modify

trans2es/management/commands/trans2es_data2es_parallel.py

@@ -201,13 +201,16 @@ class Command(BaseCommand):
             collection_redis_key_name = "physical:official_tag_name_set"
             tag_list = list(TopicTag.objects.filter(is_online=True, is_collection=True).values_list("tag_id", flat=True))
 
-            logging.info("duan add,tag_list_len:%d" % len(tag_list))
-            tag_name_list = Tag.objects.filter(id__in=tag_list, is_online=True, is_deleted=False,
-                                          is_category=False).values_list("name", flat=True)
+            tag_name_list = list(Tag.objects.filter(id__in=tag_list, is_online=True, is_deleted=False,
+                                          is_category=False).values_list("name", flat=True))
 
+            logging.info("duan add,tag_list_len:%d,tag_name_list_len:%d" % (len(tag_list),len(tag_name_list)))
             for tag_name in tag_name_list:
-                if tag_name and len(tag_name)>0 and tag_name[0]:
-                    redis_client.sadd(collection_redis_key_name,tag_name[0])
+                try:
+                    if tag_name and len(tag_name)>0 and tag_name[0]:
+                        redis_client.sadd(collection_redis_key_name,tag_name[0])
+                except:
+                    pass
         except:
             logging.error("catch exception,err_msg:%s" % traceback.format_exc())