update

task/advertisement_strategy_d.py

@@ -133,13 +133,6 @@ for t in range(0, task_days):
     #     print(res)
     # print("1-----------------------------------------------------------------------------")
     # cpc当日预算(有效口径)
-    test_sql = "select *  from online.tl_hdfs_cpc_clicklog_view"
-    cpc_budget_df = spark.sql(test_sql)
-
-    cpc_budget_df.show(1, False)
-    sql_res = cpc_budget_df.collect()
-    for res in sql_res:
-        print(res)
 
     cpc_budget_sql = """SELECT day_id,sum(budget) as budget
         FROM