个性化push指标 测试

task/ctr_push_strategy_test.py

@@ -72,7 +72,7 @@ def getSpark():
     return spark
 
 
-def getSql2(startDay, endDay):
+def getSql(startDay, endDay):
     sql = """
     --push接收数据
         SELECT partition_day
@@ -112,28 +112,6 @@ def getSql2(startDay, endDay):
     """
     return sql
 
-def getSql(startDay,endDay):
-    sql = """
-    --push接收数据
-        select *
-            from bl.bl_et_bg_trackingpushlog_inc_d
-            where partition_day=regexp_replace(DATE_SUB(current_date,1) ,'-','') 
-            limit 100
-    
-    """
-
-    # 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)