update

task/daily_search_word_count_last_two_year.py

@@ -250,7 +250,7 @@ for t in range(1, task_days):
     sql_res = search_ctr_df.collect()
     tag_names_list_week = []
     tag_dict = get_all_tag()
-    for name in sql_res:
+    for key_count,name in enumerate(sql_res):
         # print(name)
         keywords = name.query
         if not keywords:
@@ -259,8 +259,8 @@ for t in range(1, task_days):
         uv = name.all_search_uv
         is_tag = tag_dict.get(keywords, 0)
         servise_num = from_es_get_service_num(keywords)
-        pid = hashlib.md5((today_str + keywords).encode("utf8")).hexdigest()
-        tag_names_list_week.append((pid, keywords, today_str, 0, servise_num, pv, is_tag))
+        # pid = hashlib.md5((today_str + keywords).encode("utf8")).hexdigest()
+        tag_names_list_week.append((key_count, keywords, today_str, 0, servise_num, pv, is_tag))
 
     db = pymysql.connect(host='172.16.30.136', port=3306, user='doris', passwd='o5gbA27hXHHm',
                          db='doris_prod')