add

injection/data_sync/tasks.py

@@ -21,6 +21,7 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False):
         type_info = type_info_map[es_type]
 
         logging.info("duan add,es_type:%s" % str(es_type))
+        logging.info("get es_type:%s"%es_type)
         type_info.insert_table_by_pk_list(
             sub_index_name=es_type,
             pk_list=pk_list,

trans2es/type_info.py

@@ -193,6 +193,9 @@ class TypeInfo(object):
         time2=end-begin
 
         begin = time.time()
+        logging.info("get sub_index_name:%s"%sub_index_name)
+        logging.info("get data_list:%s"%data_list)
+
         self.elasticsearch_bulk_insert_data(
             sub_index_name=sub_index_name,
             data_list=data_list,