update

task/spark_test.py

@@ -80,16 +80,20 @@ spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDF
 
 
 sql_search_ctr = r"""
-SELECT
-        count(1)
-        from
+  SELECT
+        cl_id,
+        card_id,
+        transaction_type,
+        count(distinct app_session_id) as session_pv
+        FROM
         (
            SELECT 
                   cl_id,
                   card_id,
-                  app_session_id
+                  app_session_id,
+                  transaction_type
            from online.ml_community_precise_exposure_detail
-           WHERE partition_date>='{today_str}'
+           WHERE partition_date>= '${today_str}'
            AND action in ('page_precise_exposure','home_choiceness_card_exposure') --7745版本action改为page_precise_exposure
            AND is_exposure = '1'  ----精准曝光
            AND page_name ='home'
@@ -103,7 +107,7 @@ SELECT
                   transaction_type,
                   card_id,
                   app_session_id
-        )
+        ) a  group by cl_id,card_id,transaction_type
 """.format(today_str='20200922')
 
 print(sql_search_ctr)