个性化push指标 测试

task/ctr_push_strategy_test.py

@@ -72,7 +72,7 @@ def getSpark():
     return spark
 
 
-def getSql(startDay,endDay):
+def getSql2(startDay, endDay):
     sql = """
     --push接收数据
         SELECT partition_day
@@ -112,6 +112,17 @@ def getSql(startDay,endDay):
     """
     return sql
 
+def getSql(startDay,endDay):
+    sql = """
+    --push接收数据
+        select partition_day,event_type,count(*)
+            from bl.bl_et_bg_trackingpushlog_inc_d
+            where partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','')
+            group by partition_day,event_type
+    
+    """
+    return sql
+
 if __name__ == '__main__':
     if len(sys.argv) < 2:
         print('请输入day', flush=True)