Commit ff50850f authored by 高雅喆's avatar 高雅喆

update

parent c7437c80
import redis
import json
from tool import es_query
from tool import get_data_by_mysql
......@@ -174,7 +175,7 @@ if __name__ == "__main__":
for city_tag_id in all_city_tag_id:
diary_queue = search_diary_by_match_phrase(hot_search_word, city_tag_id)
hot_search_word_diary_queue.update({city_tag_id: diary_queue})
redis_client.hmset(hot_search_word_diary_queue_key, hot_search_word_diary_queue)
redis_client.hmset(hot_search_word_diary_queue_key, json.dumps(hot_search_word_diary_queue))
print("热搜词更新的日记队列长度:%s" % str(len(diary_queue)))
# 轻医美的候选队列
......@@ -195,5 +196,5 @@ if __name__ == "__main__":
for city_tag_id in all_city_tag_id:
diary_queue = search_diary_by_match_phrase(light_clinic_beauty, city_tag_id)
light_clinic_beauty_diary_queue.update({city_tag_id: diary_queue})
redis_client.hmset(light_clinic_beauty_diary_queue_key, light_clinic_beauty_diary_queue)
redis_client.hmset(light_clinic_beauty_diary_queue_key, json.dumps(light_clinic_beauty_diary_queue))
print("轻医美词更新的日记队列长度:%s" % str(len(diary_queue)))
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