update

eda/smart_rank/dist_update_user_portrait.py

@@ -71,8 +71,6 @@ def get_user_tag_score(cl_id, all_log_df, size=10):
         finally_score_lst = finally_score[["tag_id","tag_score"]].to_dict('record')
         tag_id_list = tag_list2dict(finally_score_lst, size)
         return cl_id, tag_id_list
-    else:
-        return ()
 
 
 def send_email(app,id,e):
@@ -146,7 +144,7 @@ if __name__ == '__main__':
         result_rename = result.selectExpr("_1 as cl_id", "_2 as tag_list")
         stat_date = datetime.datetime.today().strftime('%Y-%m-%d')
         result_last = result_rename.withColumn("stat_date", lit(stat_date))
-        # result_last.show()
+        result_last.show()
         result_last.write.jdbc(
             mode="overwrite",
             url="jdbc:mysql://172.16.40.158:4000/jerry_test?user=root&password=3SYz54LS9#^9sBvC",