Commit dae61179 authored by 赵威's avatar 赵威

try save

parent f12bc797
......@@ -299,17 +299,22 @@ if __name__ == "__main__":
# print("tractate: " + str(get_es_tractate(keywords)[:10]) + "\n")
# print("answer: " + str(get_es_answer(keywords)[:10]) + "\n")
all_city_tag_id = get_all_city_id()
print(all_city_tag_id)
redis_client = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN9@172.16.40.173:6379")
# diary_list = get_es_diary(keywords)
# tractate_list = get_es_tractate(keywords)
# answer_list = get_es_answer(keywords)
# redis_client = redis.StrictRedis.from_url("redis://:ReDis!GmTx*0aN9@172.16.40.173:6379")
# redis_client.rpush("doris:tag_v3:coldstart:diary", *diary_list)
# redis_client.rpush("doris:tag_v3:coldstart:tractate", *tractate_list)
# redis_client.rpush("doris:tag_v3:coldstart:answer", *answer_list)
# diary_list = get_es_diary(keywords)
# redis_client.rpush("doris:tag_v3:coldstart:diary", *diary_list)
all_city_tag_id = get_all_city_id()
for city_id in all_city_tag_id:
diary_list = get_es_diary(keywords, city_id)
redis_client.rpush("doris:test:tag_v3:coldstart:diary:" + city_id, *diary_list)
redis_client.expire("doris:test:tag_v3:coldstart:diary:" + city_id, 60 * 60 * 24)
# print("diary: " + str(len(diary_list)))
# print("tractate: " + str(len(tractate_list)))
# print("answer: " + str(len(answer_list)))
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