modify

trans2es/management/commands/trans2es_tipsdata2es.py

@@ -42,15 +42,15 @@ class Command(BaseCommand):
             type_name_list = get_type_info_map().keys()
             for type_name in type_name_list:
 
-                if len(options["type"]):
-                    if options["type"] == "all" or type_name==options["type"]:
-                        logging.info("begin sync [%s] data to es!" % type_name)
-                        type_info = tips_attr_sync_to_redis_type_info_map()[type_name]
-                        query_set = type_info.queryset
-
-                        slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size)
-                        for chunk in slicer.chunks():
-                            for instance in list(chunk):
-                                type_info.get_data_func(instance)
+                # if len(options["type"]):
+                #     if options["type"] == "all" or type_name==options["type"]:
+                logging.info("begin sync [%s] data to es!" % type_name)
+                type_info = tips_attr_sync_to_redis_type_info_map()[type_name]
+                query_set = type_info.queryset
+
+                slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size)
+                for chunk in slicer.chunks():
+                    for instance in list(chunk):
+                        type_info.get_data_func(instance)
         except:
             logging.error("catch exception,err_msg:%s" % traceback.format_exc())