update

task/spark_test.py

@@ -166,15 +166,15 @@ SELECT query,search_pv,search_uv
 					,params['query'] as query
 					,cl_id
 			FROM online.bl_hdfs_maidian_updates
-			WHERE partition_date >= start_date 
-            AND partition_date < end_date
+			WHERE partition_date >= {start_date} 
+            AND partition_date < {end_date}
 			AND ((action = 'do_search' AND params['input_type']<>'everyone_watch') or action='search_result_click_search')
 
 			UNION ALL
             SELECT partition_date,params['query'] as query,cl_id
             FROM online.bl_hdfs_maidian_updates
-            WHERE partition_date >= start_date 
-          	AND partition_date < end_date
+            WHERE partition_date >= {start_date} 
+          	AND partition_date < {end_date}
           	AND action = 'do_search'
             and params['input_type']='everyone_watch'
             and params['tab']='精选'
@@ -184,8 +184,8 @@ SELECT query,search_pv,search_uv
 			UNION ALL
             SELECT partition_date,params['query'] as query,cl_id
             FROM online.bl_hdfs_maidian_updates
-            WHERE partition_date >= start_date 
-          	AND partition_date < end_date
+            WHERE partition_date >= {start_date} 
+          	AND partition_date < {end_date}
           	AND action = 'on_click_card'
           	AND params['page_name']='search_home'
 
@@ -195,8 +195,8 @@ SELECT query,search_pv,search_uv
 					,params['card_name'] as query
 					,cl_id
 			FROM online.bl_hdfs_maidian_updates
-			WHERE partition_date >= start_date 
-            AND partition_date < end_date
+			WHERE partition_date >= {start_date} 
+            AND partition_date < {end_date}
 			AND action = 'on_click_card'
 			AND params['in_page_pos']='猜你喜欢'
 			--AND params['tab_name']='精选'
@@ -209,8 +209,8 @@ SELECT query,search_pv,search_uv
 					,params['card_name'] as query
 					,cl_id
 			FROM online.bl_hdfs_maidian_updates
-			WHERE partition_date >= start_date 
-            AND partition_date < end_date
+			WHERE partition_date >= {start_date} 
+            AND partition_date < {end_date}
 			AND action = 'on_click_card'
 			AND page_name='welfare_home'
 			AND params['card_type'] ='search_word'
@@ -221,8 +221,8 @@ SELECT query,search_pv,search_uv
 					,params['card_name'] as query
 					,cl_id
 			FROM online.bl_hdfs_maidian_updates
-			WHERE partition_date >= start_date 
-            AND partition_date < end_date
+			WHERE partition_date >= {start_date} 
+            AND partition_date < {end_date}
 			AND int(split(app_version,'\\.')[1]) >= 27
 			AND action='on_click_card'
 			AND params['card_type']='highlight_word'
@@ -242,11 +242,11 @@ SELECT query,search_pv,search_uv
                 	LEFT JOIN 
 	                (SELECT code,is_ai_channel,partition_day
 	                 FROM DIM.DIM_AI_CHANNEL_ZP_NEW
-	                 WHERE partition_day>= start_date  
-	                 AND partition_day < end_date) tmp
+	                 WHERE partition_day>= {start_date}  
+	                 AND partition_day < {end_date}) tmp
 	                ON  m.partition_date=tmp.partition_day AND first_channel_source_type=code
-                WHERE partition_date >= start_date 
-            	AND partition_date < end_date
+                WHERE partition_date >= {start_date} 
+            	AND partition_date < {end_date}
                 AND active_type in ('1','2','4')
             ) mas
             LATERAL VIEW explode(mas.channel) t2 AS channel