update import

eda/smart_rank/tag3_update_user_portrait_offline.py

@@ -5,13 +5,11 @@ import operator
 from collections import Counter
 
 import pymysql
-import pytz
-import redis
 from pyspark import SparkConf
 from pyspark.sql import SparkSession
 
-from tool import (get_doris_prod, get_jerry_test, get_redis_client, get_tag3_user_log, get_user_portrait_tag3_with_score,
-                  send_email, write_user_portrait, write_user_portrait_by_event, write_user_portrait_doris)
+from tool import (get_doris_prod, get_redis_client, get_tag3_user_log, get_user_portrait_tag3_with_score, send_email,
+                  write_user_portrait, write_user_portrait_by_event, write_user_portrait_doris)
 
 
 # [{'激光': 1.949194898204873}, {'手术': 1.949194898204873}, {'手术': 1.949194898204873}, {'手术': 1.949194898204873, '植发际线': 7.1}]
@@ -282,10 +280,10 @@ def update_tag3_user_portrait(cl_id):
             #                                                    "%Y-%m-%dT%H:%M:%S.%f")[:-7] + "Z"
             # es_insert_device_info(cl_id, body)
 
-            # # write_user_portrait_doris(cl_id, ",".join(first_solutions_score.keys()), ",".join(second_solutions_score.keys()),
-            # #                           ",".join(first_demands_score.keys()), ",".join(second_demands_score.keys()),
-            # #                           ",".join(first_positions_score.keys()), ",".join(second_positions_score.keys()),
-            # #                           ",".join(projects_score.keys()))
+            # write_user_portrait_doris(cl_id, ",".join(first_solutions_score.keys()), ",".join(second_solutions_score.keys()),
+            #                           ",".join(first_demands_score.keys()), ",".join(second_demands_score.keys()),
+            #                           ",".join(first_positions_score.keys()), ",".join(second_positions_score.keys()),
+            #                           ",".join(projects_score.keys()))
 
         return cl_id