update

eda/smart_rank/dist_update_user_portrait.py

@@ -145,8 +145,12 @@ if __name__ == '__main__':
         result = device_ids_lst_rdd.repartition(100).map(lambda x: get_user_tag_score(x, all_log_df))
         a = result.collect()
         print(a)
-        print(type(a))
-        # stat_date = datetime.datetime.today().strftime('%Y-%m-%d')
+
+        stat_date = datetime.datetime.today().strftime('%Y-%m-%d')
+        for i in a:
+            insert_sql = "insert into user_portrait_tags values({stat_date},{cl_id},{tag_list})"\
+                .format(stat_date=stat_date, cl_id=i[0], tag_list=json.dumps(i[1]))
+
         # result_last = result_rename.withColumn("stat_date", lit(stat_date))
         # result_last.show()
         # df = result_last.select("stat_date", "cl_id", concat_ws(',', 'tag_list').alias("tag_list"))