update

task/core_indicators_monitoring.py

@@ -80,21 +80,21 @@ SELECT
     ,all_search_click_pv_724 
     ,all_search_uv
     ,all_search_pv
-    ,if(dau <> 0 ,cast((all_search_uv/dau) as decimal(18,2)) , 0)
-    ,if(all_search_uv <> 0 ,concat(cast((all_search_pv/all_search_uv) as decimal(18,4)),'') , 0)
-    ,if(search_home_pv <> 0 ,cast((all_search_pv/search_home_pv) as decimal(18,4)) , 0)
-    ,if(sug_out_pv_726 <> 0 ,cast((sug_search_pv_726/sug_out_pv_726) as decimal(18,4)) , 0) 
-    ,NVL(referrer_search_hexin_pv,0)
-    ,NVL(referrer_search_welfare_pv,0)
-    ,if(all_search_uv <> 0 ,concat(cast((referrer_search_hexin_pv/dau) as decimal(18,2)),'') , 0)  
-    ,if(all_search_uv <> 0 ,concat(cast((referrer_search_neirong_pv/dau) as decimal(18,2)),'') , 0)
-    ,if(referrer_search_hexin_pv <> 0 ,cast((search_hexin_two_pv/dau)*100 as decimal(18,4)) , 0) 
-    ,if(referrer_search_neirong_pv <> 0 ,cast((search_neirong_two_pv/dau)*100 as decimal(18,4)) , 0)
-    ,if(referrer_search_neirong_uv_1000 <> 0 ,concat(cast((referrer_search_neirong_pagestay/dau) as decimal(18,4)),'') , 0)
-    ,NVL(referrer_search_neirong_pv,0)
-    ,NVL(search_hexin_two_pv,0) 
-    ,NVL(search_neirong_two_pv,0) 
-    ,NVL(referrer_search_neirong_pagestay,0)
+    ,if(dau <> 0 ,cast((all_search_uv/dau) as decimal(18,2)) , 0) as completed_user_rate
+    ,if(all_search_uv <> 0 ,concat(cast((all_search_pv/all_search_uv) as decimal(18,4)),'') , 0) as per_user_search_count
+    ,if(search_home_pv <> 0 ,cast((all_search_pv/search_home_pv) as decimal(18,4)) , 0) as search_success_rate
+    ,if(sug_out_pv_726 <> 0 ,cast((sug_search_pv_726/sug_out_pv_726) as decimal(18,4)) , 0)  as sug_uesd_rate
+    ,NVL(referrer_search_hexin_pv,0) as referrer_search_hexin_pv
+    ,NVL(referrer_search_welfare_pv,0) as referrer_search_welfare_pv
+    ,if(all_search_uv <> 0 ,concat(cast((referrer_search_hexin_pv/dau) as decimal(18,2)),'') , 0)   as search_core_pv_div_dau
+    ,if(all_search_uv <> 0 ,concat(cast((referrer_search_neirong_pv/dau) as decimal(18,2)),'') , 0) as search_neirong_pv_div_dau
+    ,if(referrer_search_hexin_pv <> 0 ,cast((search_hexin_two_pv/dau)*100 as decimal(18,4)) , 0)  as search_core_two_pv_div_dau
+    ,if(referrer_search_neirong_pv <> 0 ,cast((search_neirong_two_pv/dau)*100 as decimal(18,4)) , 0) as search_neirong_two_div_dau
+    ,if(referrer_search_neirong_uv_1000 <> 0 ,concat(cast((referrer_search_neirong_pagestay/dau) as decimal(18,4)),'') , 0) as search_neirong_per_duration
+    ,NVL(referrer_search_neirong_pv,0) as referrer_search_neirong_pv
+    ,NVL(search_hexin_two_pv,0)  as search_hexin_two_pv
+    ,NVL(search_neirong_two_pv,0) as search_neirong_two_pv
+    ,NVL(referrer_search_neirong_pagestay,0) as referrer_search_neirong_pagestay
 FROM
 (
     SELECT
@@ -559,20 +559,26 @@ FROM
         referrer_search_hexin_pv = res.referrer_search_hexin_pv
         referrer_search_welfare_pv = res.referrer_search_welfare_pv
         search_core_pv_div_dau = res.search_core_pv_div_dau
+        search_neirong_pv_div_dau = res.search_neirong_pv_div_dau
         search_core_two_div_dau = res.search_core_two_div_dau
         search_neirong_two_div_dau = res.search_neirong_two_div_dau
         search_neirong_per_duration = res.search_neirong_per_duration
         referrer_search_neirong_pv = res.referrer_search_neirong_pv
+        search_hexin_two_pv = res.search_hexin_two_pv
         pid = hashlib.md5((partition_date + device_os_type + active_type + channel).encode("utf8")).hexdigest()
         instert_sql = """replace into core_indicators_monitoring(
             partition_date,device_os_type,active_type,channel,dau,all_search_click_uv_724,all_search_click_pv_724,all_search_uv,all_search_pv,completed_user_rate,per_user_search_count,
-            search_success_rate,sug_uesd_rate,referrer_search_hexin_pv,referrer_search_welfare_pv,search_core_pv_div_dau,search_core_two_div_dau,search_neirong_two_div_dau,search_neirong_per_duration,referrer_search_neirong_pv,pid
+            search_success_rate,sug_uesd_rate,referrer_search_hexin_pv,referrer_search_welfare_pv,search_core_pv_div_dau,search_core_two_div_dau,search_neirong_two_div_dau,search_neirong_per_duration,referrer_search_neirong_pv,pid,search_neirong_pv_div_dau,search_hexin_two_pv
             ) VALUES('{partition_date}','{device_os_type}','{active_type}','{channel}',{dau},{all_search_click_uv_724},{all_search_click_pv_724},{all_search_uv},{all_search_pv},{completed_user_rate},{per_user_search_count},
-            {search_success_rate},{sug_uesd_rate},{referrer_search_hexin_pv},{referrer_search_welfare_pv},{search_core_pv_div_dau},{search_core_two_div_dau},{search_neirong_two_div_dau},{search_neirong_per_duration},{referrer_search_neirong_pv},'{pid}');""".format(
+            {search_success_rate},{sug_uesd_rate},{referrer_search_hexin_pv},{referrer_search_welfare_pv},{search_core_pv_div_dau},{search_core_two_div_dau},{search_neirong_two_div_dau},{search_neirong_per_duration},{referrer_search_neirong_pv},'{pid}',{search_neirong_pv_div_dau},{search_hexin_two_pv});""".format(
             partition_date=partition_date, device_os_type=device_os_type,
             active_type=active_type, channel=channel, dau=dau,
             all_search_click_uv_724=all_search_click_uv_724,all_search_click_pv_724=all_search_click_uv_724,all_search_uv=all_search_uv,all_search_pv=all_search_pv,completed_user_rate=completed_user_rate,per_user_search_count=per_user_search_count,
-            search_success_rate=search_success_rate,sug_uesd_rate=sug_uesd_rate,referrer_search_hexin_pv=referrer_search_hexin_pv,referrer_search_welfare_pv=referrer_search_welfare_pv,search_core_pv_div_dau=search_core_pv_div_dau,search_core_two_div_dau=search_core_two_div_dau,search_neirong_two_div_dau=search_neirong_two_div_dau,search_neirong_per_duration=search_neirong_per_duration,referrer_search_neirong_pv=referrer_search_neirong_pv,pid=pid
+            search_success_rate=search_success_rate,sug_uesd_rate=sug_uesd_rate,referrer_search_hexin_pv=referrer_search_hexin_pv,
+            referrer_search_welfare_pv=referrer_search_welfare_pv,search_core_pv_div_dau=search_core_pv_div_dau,
+            search_core_two_div_dau=search_core_two_div_dau,search_neirong_two_div_dau=search_neirong_two_div_dau,
+            search_neirong_per_duration=search_neirong_per_duration,referrer_search_neirong_pv=referrer_search_neirong_pv,
+            pid=pid,search_neirong_pv_div_dau=search_neirong_pv_div_dau,search_hexin_two_pv=search_hexin_two_pv
 
         )
         print(instert_sql)