rm user_i

eda/smart_rank/dist_update_user_portrait.py

@@ -110,7 +110,7 @@ def get_user_tag_score(cl_id, all_log_df, stat_date, size=10):
             finally_score_lst = finally_score[["tag_id","tag_score"]].to_dict('record')
             tag_id_list = tag_list2dict(finally_score_lst, size)
 
-            replace_sql = """replace into user_portrait_tags (stat_date, cl_id, user_id, tag_list) values("{stat_date}","{cl_id}","{tag_list}")"""\
+            replace_sql = """replace into user_portrait_tags (stat_date, cl_id, cl_id, tag_list) values("{stat_date}","{cl_id}","{tag_list}")"""\
                 .format(stat_date=stat_date, cl_id=cl_id, tag_list=tag_id_list)
             cur_jerry_test.execute(replace_sql)
             db_jerry_test.commit()