|
|
@@ -11,6 +11,7 @@ from datetime import datetime
|
|
|
from model.DateUtils import DateUtils
|
|
|
from model.DataBaseUtils import MysqlUtils
|
|
|
db = MysqlUtils()
|
|
|
+from model.DingTalkUtils import DingTalkUtils
|
|
|
logging.getLogger().setLevel(logging.WARNING)
|
|
|
du = DateUtils()
|
|
|
|
|
|
@@ -51,6 +52,7 @@ def daily_reports_get(access_token, account_id, st, et,level, fields):
|
|
|
r = requests.get(url, params=parameters).json()
|
|
|
if r['code'] != 0:
|
|
|
print(r['code'], r['message'])
|
|
|
+ DingTalkUtils.send('消耗日报请求超频')
|
|
|
|
|
|
return r
|
|
|
|
|
|
@@ -103,7 +105,7 @@ def get_daily_vx(st,et):
|
|
|
print("获取vx账号：",token_list_v.__len__())
|
|
|
|
|
|
time1 = time.time()
|
|
|
- executor = ThreadPoolExecutor(max_workers=20)
|
|
|
+ executor = ThreadPoolExecutor(max_workers=10)
|
|
|
li=[]
|
|
|
for y in token_list_v:
|
|
|
executor.submit(get_v_data,y,li,st,et)
|
