Commit 5935fa28 authored by 赵威's avatar 赵威

try get data

parent 45e28b13
......@@ -157,6 +157,9 @@ def update_tag3_user_portrait(cl_id):
if k not in forbidden_set:
projects_score[k] = v
if (len(first_demands_score) == 0) and (len(first_solutions_score) == 0) and (len(first_positions_list) == 0):
pass
res = {
"first_demands": first_demands_score,
"second_demands": second_demands_score,
......@@ -167,20 +170,23 @@ def update_tag3_user_portrait(cl_id):
"projects": projects_score
}
print(res)
key = "doris:user_portrait:tag3: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 \
(len(first_solutions_score.keys()) > 0) or (len(second_solutions_score.keys()) > 0) or \
(len(first_positions_score.keys()) > 0) or (len(second_positions_score.keys()) > 0) or \
(len(projects_score.keys()) > 0):
redis_client.set(key, json.dumps(res))
redis_client.expire(key, 60 * 60 * 24 * 30)
# TODO
# if (len(first_demands_score.keys()) > 0) or (len(second_demands_score.keys()) > 0) or \
# (len(first_solutions_score.keys()) > 0) or (len(second_solutions_score.keys()) > 0) or \
# (len(first_positions_score.keys()) > 0) or (len(second_positions_score.keys()) > 0) or \
# (len(projects_score.keys()) > 0):
# redis_client.set(key, json.dumps(res))
# redis_client.expire(key, 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()))
# 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()))
return cl_id
......@@ -226,7 +232,10 @@ def consume_kafka():
if __name__ == "__main__":
start = datetime.datetime.now()
# update_tag3_user_portrait("androidid_a25a1129c0b38f7b")
consume_kafka()
# TODO
device_id = "862460044588666"
update_tag3_user_portrait(device_id)
# consume_kafka()
end = datetime.datetime.now()
print(end - start)
print("done")
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment