update

task/spark_test.py

@@ -93,13 +93,15 @@ spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDF
 # huidu_device_id_df = spark.sql(huidu_device_id_sql)
 # huidu_device_id_df.createOrReplaceTempView("dev_view")
 sql_search_ctr = r"""
-SELECT *
+    SELECT *
             FROM online.bl_hdfs_maidian_updates
-            WHERE partition_date >= '{start_date}'
-              AND partition_date < '{end_date}'
-              AND action = 'on_click_navbar_search'
-         limit 20
-""".format(start_date='20201105',end_date='20201025')
+            WHERE partition_date >= '${start_date}'
+              AND partition_date < '${end_date}'
+              AND action = 'on_click_card'
+              AND params['page_name']='welfare_home'
+              AND params['card_type'] ='search_word'
+              AND params['in_page_pos']='大家都在搜'
+""".format(start_date='20201116',end_date='20201117')
 
 print(sql_search_ctr)
 search_ctr_df = spark.sql(sql_search_ctr)