Browse Source

MOD:素材数据获取,添加timeout,限制时长过长问题

cxyu 3 năm trước cách đây
mục cha
commit
739037c1bf

+ 2 - 2
app/api_data/tx_ad_cost/campaign_cost_daily.py

@@ -56,7 +56,7 @@ def mp_campaign_daily_report(account_id,access_token, start_date, end_date):
 			if type(parameters[k]) is not str:
 				parameters[k] = json.dumps(parameters[k])
 
-		r = requests.get(url, params=parameters).json()
+		r = requests.get(url, params=parameters,timeout=5).json()
 		data = r['data']['list']
 		li.extend(data)
 		total_page = r['data']['page_info']['total_page']
@@ -101,7 +101,7 @@ def gdt_campaign_daily_report(account_id,access_token, start_date, end_date):
 			if type(parameters[k]) is not str:
 				parameters[k] = json.dumps(parameters[k])
 
-		r = requests.get(url, params=parameters).json()
+		r = requests.get(url, params=parameters,timeout=5).json()
 		data = r['data']['list']
 		li.extend(data)
 		total_page = r['data']['page_info']['total_page']

+ 8 - 8
app/api_data/tx_ad_cost/cost_util.py

@@ -50,7 +50,7 @@ def get_campaign(account_id, access_token, flag, campaign_ids, dt):
                 parameters[k] = json.dumps(parameters[k])
 
         while True:
-            r = requests.get(url, params=parameters).json()
+            r = requests.get(url, params=parameters,timeout=5).json()
             code = r['code']
             if code == 11017:
                 time.sleep(61)
@@ -259,7 +259,7 @@ def images_info_get(account_id, access_token, image_ids):  # 获取图片信息
                     parameters[k] = json.dumps(parameters[k])
 
             while True:
-                h = requests.get(url, params=parameters)
+                h = requests.get(url, params=parameters,timeout=5)
                 # logging.info(h.text)
                 if h.status_code == 200:
                     r = h.json()
@@ -351,7 +351,7 @@ def video_info_get(account_id, access_token, image_ids):  # 获取视频信息
                     parameters[k] = json.dumps(parameters[k])
 
             while True:
-                h = requests.get(url, params=parameters)
+                h = requests.get(url, params=parameters,timeout=5)
                 # logging.info(h.text)
                 if h.status_code == 200:
                     r = h.json()
@@ -443,7 +443,7 @@ def get_ad_info(account_id, access_token, flag, ad_ids, dt):
                 parameters[k] = json.dumps(parameters[k])
 
         while True:
-            r = requests.get(url, params=parameters).json()
+            r = requests.get(url, params=parameters,timeout=5).json()
             code = r['code']
             if code == 11017:
                 time.sleep(61)
@@ -504,7 +504,7 @@ def ad_cost_day_gdt(account_id, access_token, st, et):
             if type(parameters[k]) is not str:
                 parameters[k] = json.dumps(parameters[k])
         while True:
-            r = requests.get(url, params=parameters)
+            r = requests.get(url, params=parameters,timeout=5)
             r = r.json()
             # logging.info(r)
             code = r['code']
@@ -564,7 +564,7 @@ def ad_cost_day_mp(account_id, access_token, st, et):
                 parameters[k] = json.dumps(parameters[k])
 
         while True:
-            r = requests.get(url, params=parameters)
+            r = requests.get(url, params=parameters,timeout=5)
             r = r.json()
             # logging.info(r['data']['list'])
             # import pandas as pd
@@ -652,7 +652,7 @@ def daily_reports_get(access_token, account_id, level, start_date, end_date, fie
             parameters[k] = json.dumps(parameters[k])
 
     while True:
-        r = requests.get(url, params=parameters)
+        r = requests.get(url, params=parameters,timeout=5)
         if r.status_code == 200:
             break
         else:
@@ -708,7 +708,7 @@ def daily_qq_reports_get(access_token, account_id, compaign_id, level, start_dat
         if type(parameters[k]) is not str:
             parameters[k] = json.dumps(parameters[k])
 
-    r = requests.get(url, params=parameters)
+    r = requests.get(url, params=parameters,timeout=5)
 
     return r.json()
 

+ 3 - 3
app/api_data/tx_ad_cost/get_cost.py

@@ -189,9 +189,9 @@ if __name__ == '__main__':
     # campaign('2021-05-14')
     # ad_cost_day(du.get_n_days(-365), du.get_n_days(0))
 
-    for dt in list(du.getDateLists(du.get_n_days(-10), du.get_n_days(0))):
-        print(dt)
-        campaign(dt)
+    # for dt in list(du.getDateLists(du.get_n_days(-10), du.get_n_days(0))):
+    #     print(dt)
+    #     campaign(dt)
     # run(dt)
     # ad(dt)
     # adcreative(dt)

+ 1 - 1
app/api_data/tx_ad_cost/get_cost_older.py

@@ -48,7 +48,7 @@ def daily_reports_get(access_token, account_id, st, et, level, fields, err_num=0
         if type(parameters[k]) is not str:
             parameters[k] = json.dumps(parameters[k])
 
-    r = requests.get(url, params=parameters).json()
+    r = requests.get(url, params=parameters,timeout=5).json()
     logging.info('account_id: {} 开始获取消耗数据'.format(account_id))
     if r['code'] != 0:
         logging.warning(