修复埋点变化

task/daily_search_word_count.py

@@ -123,7 +123,7 @@ for t in range(0, task_days):
                              'search_home'   as page_name,
                              ''              as input_type,
                              app_version,
-                             params['query'] as query
+                             coalesce(params['query'],params['card_name']) as query
                       FROM online.bl_hdfs_maidian_updates
                       WHERE partition_date >= '{start_date}'
                         AND partition_date < '{end_date}'

task/daily_search_word_count_fix.py

@@ -130,7 +130,7 @@ for t in range(0, task_days):
                              'search_home'   as page_name,
                              ''              as input_type,
                              app_version,
-                             params['query'] as query
+                             coalesce(params['query'],params['card_name']) as query
                       FROM online.bl_hdfs_maidian_updates
                       WHERE partition_date >= '{start_date}'
                         AND partition_date < '{end_date}'

task/daily_search_word_count_last_two_year.py

@@ -220,7 +220,7 @@ for t in range(1, task_days):
                              'search_home'   as page_name,
                              ''              as input_type,
                              app_version,
-                             params['query'] as query
+                             coalesce(params['query'],params['card_name']) as query
                       FROM online.bl_hdfs_maidian_updates
                       WHERE partition_date >= '{start_date}'
                         AND partition_date < '{end_date}'

task/search_strategy_d.py

@@ -186,7 +186,7 @@ for t in range(0, task_days):
     			AND action in ('do_search','search_result_click_search')
 
     			UNION ALL
-                SELECT partition_date,params['query'] as query,cl_id
+                SELECT partition_date,coalesce(params['query'],params['card_name']) as query,cl_id
                 FROM online.bl_hdfs_maidian_updates
                 WHERE partition_date >= {yesterday_str}
               	AND partition_date < {today_str}