update

task/advertisement_strategy_d.py

@@ -104,14 +104,14 @@ for t in range(0, task_days):
     for res in sql_res:
         print(res)
 
-
+    print("-----------------------------------------------------------------------------")
     # 商详页PV
     bus_detail_pv_sql = """SELECT 
     partition_date,count(1) welfare_pv
     FROM 
     (
         SELECT cl_id,partition_date
-        FROM bl_hdfs_maidian_updates
+        FROM online.bl_hdfs_maidian_updates
         WHERE partition_date >='{start_date}'and partition_date < '{end_date}'
         AND action='page_view'
         AND params['page_name'] = 'welfare_detail'
@@ -131,7 +131,7 @@ for t in range(0, task_days):
     sql_res = bus_detail_pv_df.collect()
     for res in sql_res:
         print(res)
-
+    print("-----------------------------------------------------------------------------")
     # cpc当日预算(有效口径)
     cpc_budget_sql = """SELECT day_id,sum(budget) as budget
         FROM
@@ -189,7 +189,7 @@ for t in range(0, task_days):
     sql_res = cpc_budget_df.collect()
     for res in sql_res:
         print(res)
-
+    print("-----------------------------------------------------------------------------")
     cpc_income_total_consume_sql = """
     select partition_day,
 sum(case when advertise_type = 'cpc' AND advertise_business_type in('service') and advertise_calculate_type='cpc_log' then cpc_click_num end)   cpc_click_num,