Ver Fonte

定时任务添加打印信息到log里

liyuyi@c-top.com.cn há 4 anos atrás
pai
commit
781de7a24f

+ 3 - 1
time_task/time_task_ai_check_and_up_to_full_creative.py

@@ -18,7 +18,7 @@ def send_request(account_id):
 
 
 # 0、 打印该定时任务被调用的时间
-print(datetime.datetime.now())
+print("*************************", datetime.datetime.now(), "*************************")
 
 # 1、获取已有的账号
 sql = """
@@ -32,12 +32,14 @@ print(acc_list)
 batch_num = 5
 for i in range(0, len(acc_list), batch_num):
     if i + batch_num < len(acc_list):
+        print(tuple(acc_list[i:i+batch_num]))
         with ThreadPoolExecutor(max_workers=batch_num) as pool:
             results = pool.map(send_request, tuple(acc_list[i: i+batch_num]))
             for r in results:
                 print('res = %s' % r)
     else:
         with ThreadPoolExecutor(max_workers=batch_num) as pool:
+            print(acc_list[i: len(acc_list)])
             results = pool.map(send_request, tuple(acc_list[i: len(acc_list)]))
             for r in results:
                 print('res = %s' % r)

+ 3 - 1
time_task/time_task_ai_high_quality_material.py

@@ -18,7 +18,7 @@ def send_request(account_id):
 
 
 # 0、 打印该定时任务被调用的时间
-print(datetime.datetime.now())
+print("*************************", datetime.datetime.now(), "*************************")
 
 # 1、获取已有的账号
 sql = """
@@ -32,12 +32,14 @@ print(acc_list)
 batch_num = 5
 for i in range(0, len(acc_list), batch_num):
     if i + batch_num < len(acc_list):
+        print(tuple(acc_list[i:i + batch_num]))
         with ThreadPoolExecutor(max_workers=batch_num) as pool:
             results = pool.map(send_request, tuple(acc_list[i: i+batch_num]))
             for r in results:
                 print('res = %s' % r)
     else:
         with ThreadPoolExecutor(max_workers=batch_num) as pool:
+            print(acc_list[i: len(acc_list)])
             results = pool.map(send_request, tuple(acc_list[i: len(acc_list)]))
             for r in results:
                 print('res = %s' % r)

+ 4 - 1
time_task/time_task_ai_historical_missing_material.py

@@ -18,7 +18,8 @@ def send_request(account_id):
 
 
 # 0、 打印该定时任务被调用的时间
-print(datetime.datetime.now())
+print("*************************", datetime.datetime.now(), "*************************")
+
 
 # 1、获取已有的账号
 sql = """
@@ -32,12 +33,14 @@ print(acc_list)
 batch_num = 5
 for i in range(0, len(acc_list), batch_num):
     if i + batch_num < len(acc_list):
+        print(tuple(acc_list[i:i + batch_num]))
         with ThreadPoolExecutor(max_workers=batch_num) as pool:
             results = pool.map(send_request, tuple(acc_list[i: i+batch_num]))
             for r in results:
                 print('res = %s' % r)
     else:
         with ThreadPoolExecutor(max_workers=batch_num) as pool:
+            print(acc_list[i: len(acc_list)])
             results = pool.map(send_request, tuple(acc_list[i: len(acc_list)]))
             for r in results:
                 print('res = %s' % r)