个性化push指标 测试

task/ctr_push_strategy_test.py

@@ -80,6 +80,14 @@ def getSql(startDay,endDay):
                     where partition_date >= {startDay} and partition_date<{endDay} and push_type in ('101','102','111','112')
                     group by partition_date,push_type
                     
+        union all
+        
+        SELECT partition_date,regexp_replace(labels['event'], '\\s+', '') AS push_type,count(*)
+        FROM online.tl_hdfs_push2_task_view
+        WHERE partition_date >= '20210618' and partition_date<'20210619'
+        AND labels['event_type'] = 'push'
+        group by  partition_date,regexp_replace(labels['event'], '\\s+', '')
+    
     """.format(startDay=startDay,endDay=endDay)
     return sql