update

task/daily_search_word_count.py

@@ -189,9 +189,9 @@ for t in range(0, task_days):
     sql_res = search_ctr_df.collect()
     tag_names_list_week = []
     for name in sql_res:
-        word = name.get("query")
-        nums = name.get("all_search_pv")
-        uv = name.get("all_search_uv")
+        word = name.query
+        nums = name.all_search_pv
+        uv = name.all_search_uv
         partition_date = str(now + datetime.timedelta(days=-1))
         tag_names_list_week.append((word, nums, uv, partition_date))