diff --git a/eda/smart_rank/tag3_update_user_portrait_offline.py b/eda/smart_rank/tag3_update_user_portrait_offline.py index 1a5a233de251c52b7891586fa2f86343104f9f25..2404e116088c0108c05984eba8d0a8dd05495958 100644 --- a/eda/smart_rank/tag3_update_user_portrait_offline.py +++ b/eda/smart_rank/tag3_update_user_portrait_offline.py @@ -71,7 +71,6 @@ def update_tag3_user_portrait(cl_id): } key = "doris:user_portrait:tag3:device_id:" + str(cl_id) - key2 = "doris:user_portrait:tag3:increment_update:device_id:" + str(cl_id) redis_client = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN9@172.16.40.173:6379") if (len(first_demands_score.keys()) > 0) or (len(second_demands_score.keys()) > 0) or \ @@ -82,25 +81,23 @@ def update_tag3_user_portrait(cl_id): redis_client.expire(key, 60 * 60 * 24 * 30) # only need the first time - res2 = { - "first_demands": list(first_demands_score.keys()), - "second_demands": list(second_demands_score.keys()), - "first_solutions": list(first_solutions_score.keys()), - "second_solutions": list(second_solutions_score.keys()), - "first_positions": list(first_positions_score.keys()), - "second_positions": list(second_positions_score.keys()), - "projects": list(projects_score.keys()) - } - redis_client.set(key2, json.dumps(res2)) - redis_client.expire(key2, 60 * 60 * 24 * 30) + # key2 = "doris:user_portrait:tag3:increment_update:device_id:" + str(cl_id) + # res2 = { + # "first_demands": list(first_demands_score.keys()), + # "second_demands": list(second_demands_score.keys()), + # "first_solutions": list(first_solutions_score.keys()), + # "second_solutions": list(second_solutions_score.keys()), + # "first_positions": list(first_positions_score.keys()), + # "second_positions": list(second_positions_score.keys()), + # "projects": list(projects_score.keys()) + # } + # redis_client.set(key2, json.dumps(res2)) + # redis_client.expire(key2, 60 * 60 * 24 * 30) write_user_portrait(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())) - else: - redis_client.delete(key) - redis_client.delete(key2) return cl_id