1

app/api_data/get_cost.py

@@ -3,6 +3,7 @@ from app.api_data.cost_util import *
 from model.DateUtils import DateUtils
 from model.DataBaseUtils import MysqlUtils
 from concurrent.futures import ThreadPoolExecutor
+from model.DingTalkUtils import DingTalkUtils
 db = MysqlUtils()
 du = DateUtils()
 
@@ -93,12 +94,14 @@ def day():
 	3.用第2步获取的创意id 去拉取广告创意基础信息
 	4.用创意信息中的图片id 去获取图片的基础信息
 	"""
-
-	dt = du.getNow()
-	ad_cost_day(dt)
-	ad(dt)
-	adcreative(dt)
-	image(dt)
+	try:
+		dt = du.getNow()
+		ad_cost_day(dt)
+		ad(dt)
+		adcreative(dt)
+		image(dt)
+	except:
+		DingTalkUtils.send("拉取广告数据出错")
 
 
 if __name__ == '__main__':

app/dailyRun.py

@@ -1,6 +1,9 @@
 from app.api_data import get_order
 from app.etl import data_stat_run
 from model.DateUtils import DateUtils
+from app.api_data import get_cost
+from app.etl.dw import dw_ad_day
+from model.DingTalkUtils import DingTalkUtils
 du = DateUtils()
 
 
@@ -17,5 +20,12 @@ if __name__ == '__main__':
     # 阳光订单
     get_order.daily_yg()
 
+    # 广告数据
+
+    get_cost.day()  # 广告相关消耗数据
+    dw_ad_day.day()
+
+
+
 
 

app/etl/ad_cost_day_run.py

@@ -1,15 +0,0 @@
-from app.api_data import get_cost
-from app.etl.dw import dw_ad_day
-from model.DingTalkUtils import DingTalkUtils
-
-if __name__ == '__main__':
-    try:
-        get_cost.day() # 广告相关消耗数据
-    except:
-        DingTalkUtils.send('广告消耗数据拉取出错')
-        exit(0)
-
-    try:
-        dw_ad_day.day()
-    except:
-        DingTalkUtils.send("广告数据清洗出错")

app/etl/dw/dw_ad_day.py

@@ -1,6 +1,7 @@
 import logging
 from model.DataBaseUtils import MysqlUtils,CkUtils
 from model.DateUtils import DateUtils
+from model.DingTalkUtils import DingTalkUtils
 logging.getLogger().setLevel(logging.WARNING)
 import pandas as pd
 db = MysqlUtils()
@@ -56,7 +57,11 @@ def run(dt):
 
 
 def day():
-    run(du.getNow())
+    try:
+        run(du.getNow())
+    except:
+        DingTalkUtils.send("广告数据清洗失败")
+
 
 
 if __name__ == '__main__':