modify

trans2es/type_info.py

@@ -252,7 +252,7 @@ def get_type_info_map():
             model=user.User,
             #query_deferred=lambda:user.User.objects.all().query,
             #query_deferred=lambda: user.User.objects.prefetch_related('myuserfollow').query,
-            query_deferred=lambda: user.User.objects.all().query,
+            query_deferred=lambda: user.User.objects.filter(create_time__isnull=False,update_time__isnull=False),
             get_data_func=UserTransfer.get_user_data,
             bulk_insert_chunk_size=100,
             round_insert_chunk_size=5,

trans2es/utils/user_transfer.py

@@ -41,6 +41,7 @@ class UserTransfer(object):
                 logging.error("duan test,catch exception,err_msg:%s" % traceback.format_exc())
                 res["latest_topic_time_val"] = -1
 
+
             tzlc_create_time = tzlc(instance.create_time)
             res["create_time"] = tzlc_create_time
             res["create_time_val"] = int(time.mktime(tzlc_create_time.timetuple()))
@@ -49,6 +50,7 @@ class UserTransfer(object):
             res["update_time"] = tzlc_update_time
             res["update_time_val"] = int(time.mktime(tzlc_update_time.timetuple()))
 
+
             res["tag_list"] = []
             res["attention_user_id_list"] = []
             res["attention_group_id_list"] = []