update

task/daily_search_word_count_last_two_year.py

@@ -168,13 +168,13 @@ for t in range(1, task_days):
     last_two_year_str = (now + datetime.timedelta(days=-370)).strftime("%Y%m%d")
     # one_week_age_str = (now + datetime.timedelta(days=-7)).strftime("%Y%m%d")
     keyword_sql = """
-    select name from wiki_item where is_online=True
+    select name from zhengxing.wiki_item where is_online=True
     union 
-    select name from wiki_product where is_online=True
+    select name from zhengxing.wiki_product where is_online=True
     union 
-    select name from wiki_collect where is_online=True
+    select name from zhengxing.wiki_collect where is_online=True
     union 
-    select name from wiki_brand where is_online=True
+    select name from zhengxing.wiki_brand where is_online=True
     """
     keyword_df = spark.sql(keyword_sql)
     keyword_df.createOrReplaceTempView("keywords_table")