Jelajahi Sumber

1、commonfunction的logger独立为一个文件2、端口31018改为31012 3、常量文件中新增了app_id的数量方便测试

liyuyi@c-top.com.cn 4 tahun lalu
induk
melakukan
d3d7474c3d

+ 1 - 1
ai_ads_main.py

@@ -29,7 +29,7 @@ def create_application():
 if __name__ == "__main__":
 if __name__ == "__main__":
     application = create_application()
     application = create_application()
     http_server = tornado.httpserver.HTTPServer(application)
     http_server = tornado.httpserver.HTTPServer(application)
-    http_server.bind(31018, None)
+    http_server.bind(31012, None)
     if platform.system() == 'Windows':
     if platform.system() == 'Windows':
         http_server.start()
         http_server.start()
     else:
     else:

+ 5 - 5
ai_time_task_creative_handler.py

@@ -6,11 +6,11 @@ import traceback
 import random
 import random
 import tornado.web
 import tornado.web
 from concurrent_log import ConcurrentTimedRotatingFileHandler
 from concurrent_log import ConcurrentTimedRotatingFileHandler
-from utils.CommonFunction import get_history_video_info, get_new_video_info, get_missing_video_info, \
-                                 get_top_video_info, get_campaign_and_group_name_rule,get_app_detail, get_request_data
 from utils.ConstantConfig import *
 from utils.ConstantConfig import *
-from ai_strategy_request_func import ai_strategy_request_parse
 from utils.DataBaseConfig import *
 from utils.DataBaseConfig import *
+from utils.CommonFunction import get_history_video_info, get_new_video_info, get_missing_video_info, \
+                                 get_top_video_info, get_campaign_and_group_name_rule, get_app_detail, get_request_data
+from ai_strategy_request_func import ai_strategy_request_parse
 
 
 log_formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s', '%m/%d/%Y %I:%M:%S %p')
 log_formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s', '%m/%d/%Y %I:%M:%S %p')
 log_handler = ConcurrentTimedRotatingFileHandler("logs/ai_auto_create.log", when="midnight", backupCount=100)
 log_handler = ConcurrentTimedRotatingFileHandler("logs/ai_auto_create.log", when="midnight", backupCount=100)
@@ -104,7 +104,7 @@ class AiHistoricalMissingMaterial(tornado.web.RequestHandler):
                         request = ai_strategy_request_parse(request_data)
                         request = ai_strategy_request_parse(request_data)
                         logger.info("account_id=%s, app_id=%s, 补充遗漏素材,ai策略的返回信息:%s" % (account_id, app_id, request))
                         logger.info("account_id=%s, app_id=%s, 补充遗漏素材,ai策略的返回信息:%s" % (account_id, app_id, request))
                         app_id_cnt += 1
                         app_id_cnt += 1
-                    if app_id_cnt >= 100:
+                    if app_id_cnt >= missing_video_app_id:
                         break
                         break
                 self.write(json.dumps({"message": "account_id=%s, 多应用的补充遗漏素材请求已走完!" % account_id}))
                 self.write(json.dumps({"message": "account_id=%s, 多应用的补充遗漏素材请求已走完!" % account_id}))
                 self.flush()
                 self.flush()
@@ -355,7 +355,7 @@ class AiHighQualityMaterial(tornado.web.RequestHandler):
                         request = ai_strategy_request_parse(request_data)
                         request = ai_strategy_request_parse(request_data)
                         logger.info("account_id=%s, app_id=%s, 高质量素材复建,ai策略的返回信息:%s" % (account_id, app_id, request))
                         logger.info("account_id=%s, app_id=%s, 高质量素材复建,ai策略的返回信息:%s" % (account_id, app_id, request))
                         app_id_cnt += 1
                         app_id_cnt += 1
-                    if app_id_cnt >= 100:
+                    if app_id_cnt >= high_quality_video_app_id:
                         break
                         break
                 self.write(json.dumps({"message": "account_id=%s, 多应用的高质量素材复建请求已走完!" % account_id}))
                 self.write(json.dumps({"message": "account_id=%s, 多应用的高质量素材复建请求已走完!" % account_id}))
                 self.flush()
                 self.flush()

+ 0 - 0
logs/.__commonfunction.lock


File diff ditekan karena terlalu besar
+ 36 - 259
logs/ai_auto_create.log


File diff ditekan karena terlalu besar
+ 119 - 140
logs/ai_callback.log


+ 40 - 42
logs/ai_strategy_request.log

@@ -1,42 +1,40 @@
-02/02/2021 11:59:42 AM INFO 账户信息=9845260, 当前进程=8360, 当前进程的主进程=9536
-02/02/2021 11:59:43 AM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 11:59:47', 'account_id': 9845260, 'campaign_id': 33299135}, 'message': 'SUCCESS'}
-02/02/2021 11:59:43 AM INFO 广告计划创建成功,campaign_id = 33299135,  ai_strategy_uuid = 424ad6b4-f67f-4a39-8ad2-e75ed4e4145a
-02/02/2021 12:00:14 PM INFO 策略uuid = 424ad6b4-f67f-4a39-8ad2-e75ed4e4145a 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
-02/02/2021 01:55:39 PM INFO 账户信息=9845260, 当前进程=7068, 当前进程的主进程=9536
-02/02/2021 01:55:40 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 13:55:40', 'account_id': 9845260, 'campaign_id': 33317660}, 'message': 'SUCCESS'}
-02/02/2021 01:55:40 PM INFO 广告计划创建成功,campaign_id = 33317660,  ai_strategy_uuid = 6ab9b3ac-f005-42f4-af2d-3f780a3478f5
-02/02/2021 01:56:44 PM INFO 账户信息=9845260, 当前进程=18716, 当前进程的主进程=9536
-02/02/2021 01:56:45 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 13:56:44', 'account_id': 9845260, 'campaign_id': 33318186}, 'message': 'SUCCESS'}
-02/02/2021 01:56:45 PM INFO 广告计划创建成功,campaign_id = 33318186,  ai_strategy_uuid = 1fd6f34c-7e73-4424-b3f2-28d7b83a3fca
-02/02/2021 01:56:47 PM INFO 策略uuid = 1fd6f34c-7e73-4424-b3f2-28d7b83a3fca 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
-02/02/2021 02:07:44 PM INFO 账户信息=9845260, 当前进程=18716, 当前进程的主进程=9536
-02/02/2021 02:07:46 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 14:07:46', 'account_id': 9845260, 'campaign_id': 33320595}, 'message': 'SUCCESS'}
-02/02/2021 02:07:46 PM INFO 广告计划创建成功,campaign_id = 33320595,  ai_strategy_uuid = 6ed85b86-e805-4cea-8942-aa7fbc29ebcb
-02/02/2021 02:07:48 PM INFO 策略uuid = 6ed85b86-e805-4cea-8942-aa7fbc29ebcb 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
-02/02/2021 02:23:36 PM INFO 账户信息=9845260, 当前进程=8116, 当前进程的主进程=9536
-02/02/2021 02:23:38 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 14:23:37', 'account_id': 9845260, 'campaign_id': 33327870}, 'message': 'SUCCESS'}
-02/02/2021 02:23:38 PM INFO 广告计划创建成功,campaign_id = 33327870,  ai_strategy_uuid = cdb34066-f8ab-4f37-94b8-24dd342184fd
-02/02/2021 02:25:08 PM INFO 账户信息=9845260, 当前进程=17940, 当前进程的主进程=9536
-02/02/2021 02:25:09 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 14:25:08', 'account_id': 9845260, 'campaign_id': 33328565}, 'message': 'SUCCESS'}
-02/02/2021 02:25:09 PM INFO 广告计划创建成功,campaign_id = 33328565,  ai_strategy_uuid = e4184104-92c7-4d1b-9912-93d41121852c
-02/02/2021 02:25:11 PM INFO 策略uuid = e4184104-92c7-4d1b-9912-93d41121852c 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
-02/02/2021 02:28:00 PM INFO 账户信息=9845260, 当前进程=17940, 当前进程的主进程=9536
-02/02/2021 02:28:01 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 14:28:01', 'account_id': 9845260, 'campaign_id': 33329272}, 'message': 'SUCCESS'}
-02/02/2021 02:28:01 PM INFO 广告计划创建成功,campaign_id = 33329272,  ai_strategy_uuid = 7ba1863d-7fa1-4393-996c-4bd0d2f4e58d
-02/02/2021 02:28:05 PM INFO 策略uuid = 7ba1863d-7fa1-4393-996c-4bd0d2f4e58d 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
-02/02/2021 02:43:00 PM INFO 账户信息=9845260, 当前进程=13992, 当前进程的主进程=9536
-02/02/2021 02:43:00 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 14:43:00', 'account_id': 9845260, 'campaign_id': 33335107}, 'message': 'SUCCESS'}
-02/02/2021 02:43:00 PM INFO 广告计划创建成功,campaign_id = 33335107,  ai_strategy_uuid = 54e40072-15a0-4bf4-ace1-db01dcb0b6fe
-02/02/2021 02:43:04 PM INFO 策略uuid = 54e40072-15a0-4bf4-ace1-db01dcb0b6fe 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
-02/02/2021 02:46:38 PM INFO 账户信息=9845260, 当前进程=13992, 当前进程的主进程=9536
-02/02/2021 02:46:39 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 14:46:39', 'account_id': 9845260, 'campaign_id': 33338276}, 'message': 'SUCCESS'}
-02/02/2021 02:46:39 PM INFO 广告计划创建成功,campaign_id = 33338276,  ai_strategy_uuid = 2fbb09eb-9fc1-4960-b370-b2e64a6a7b61
-02/02/2021 02:46:41 PM INFO 策略uuid = 2fbb09eb-9fc1-4960-b370-b2e64a6a7b61 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
-02/02/2021 02:50:13 PM INFO 账户信息=9845260, 当前进程=13992, 当前进程的主进程=9536
-02/02/2021 02:50:14 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 14:50:14', 'account_id': 9845260, 'campaign_id': 33340373}, 'message': 'SUCCESS'}
-02/02/2021 02:50:14 PM INFO 广告计划创建成功,campaign_id = 33340373,  ai_strategy_uuid = f9f3e2a1-3829-40bd-9103-c73fb7ad8919
-02/02/2021 02:50:16 PM INFO 策略uuid = f9f3e2a1-3829-40bd-9103-c73fb7ad8919 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
-02/02/2021 02:51:05 PM INFO 账户信息=9845260, 当前进程=13992, 当前进程的主进程=9536
-02/02/2021 02:51:06 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-02 14:51:06', 'account_id': 9845260, 'campaign_id': 33340487}, 'message': 'SUCCESS'}
-02/02/2021 02:51:06 PM INFO 广告计划创建成功,campaign_id = 33340487,  ai_strategy_uuid = 4d95ce63-96c7-4745-b3cb-361abf6d468b
-02/02/2021 02:51:08 PM INFO 策略uuid = 4d95ce63-96c7-4745-b3cb-361abf6d468b 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 10:35:46 AM INFO 账户信息=9792538, 当前进程=15576, 当前进程的主进程=4728
+02/20/2021 10:35:47 AM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-20 10:35:46', 'account_id': 9792538, 'campaign_id': 35058831}, 'message': 'SUCCESS'}
+02/20/2021 10:35:47 AM INFO 广告计划创建成功,campaign_id = 35058831,  ai_strategy_uuid = 2395683b-67d4-4ecf-9833-2fe589228c22
+02/20/2021 10:35:49 AM INFO 策略uuid = 2395683b-67d4-4ecf-9833-2fe589228c22 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 10:39:29 AM INFO 账户信息=9792538, 当前进程=15576, 当前进程的主进程=4728
+02/20/2021 10:39:31 AM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-20 10:39:29', 'account_id': 9792538, 'campaign_id': 35059274}, 'message': 'SUCCESS'}
+02/20/2021 10:39:31 AM INFO 广告计划创建成功,campaign_id = 35059274,  ai_strategy_uuid = e3d3145e-0ca2-4505-9cfa-53047ecb19fb
+02/20/2021 10:39:33 AM INFO 策略uuid = e3d3145e-0ca2-4505-9cfa-53047ecb19fb 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 11:09:45 AM INFO 账户信息=9864909, 当前进程=7092, 当前进程的主进程=4728
+02/20/2021 11:09:47 AM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-20 11:09:45', 'account_id': 9864909, 'campaign_id': 35067058}, 'message': 'SUCCESS'}
+02/20/2021 11:09:47 AM INFO 广告计划创建成功,campaign_id = 35067058,  ai_strategy_uuid = 868bb400-51e7-47b2-8ab7-42d3f7dd3c74
+02/20/2021 11:09:49 AM INFO 策略uuid = 868bb400-51e7-47b2-8ab7-42d3f7dd3c74 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 11:09:53 AM INFO 账户信息=9864909, 当前进程=7092, 当前进程的主进程=4728
+02/20/2021 11:09:55 AM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-20 11:09:53', 'account_id': 9864909, 'campaign_id': 35067380}, 'message': 'SUCCESS'}
+02/20/2021 11:09:55 AM INFO 广告计划创建成功,campaign_id = 35067380,  ai_strategy_uuid = dfc219ab-e918-4d2c-9f46-4a1b0ed7e8fb
+02/20/2021 11:09:58 AM INFO 策略uuid = dfc219ab-e918-4d2c-9f46-4a1b0ed7e8fb 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 11:18:09 AM INFO 账户信息=9864909, 当前进程=7092, 当前进程的主进程=4728
+02/20/2021 11:18:10 AM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-20 11:18:09', 'account_id': 9864909, 'campaign_id': 35071428}, 'message': 'SUCCESS'}
+02/20/2021 11:18:10 AM INFO 广告计划创建成功,campaign_id = 35071428,  ai_strategy_uuid = 22a85458-a159-4988-8909-6312d32ef35d
+02/20/2021 11:18:14 AM INFO 策略uuid = 22a85458-a159-4988-8909-6312d32ef35d 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 11:41:15 AM INFO 账户信息=9864909, 当前进程=7092, 当前进程的主进程=4728
+02/20/2021 11:41:17 AM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-20 11:41:15', 'account_id': 9864909, 'campaign_id': 35080886}, 'message': 'SUCCESS'}
+02/20/2021 11:41:17 AM INFO 广告计划创建成功,campaign_id = 35080886,  ai_strategy_uuid = cd6206d1-4a30-4dd3-8bf3-16f1440071f6
+02/20/2021 11:41:22 AM INFO 策略uuid = cd6206d1-4a30-4dd3-8bf3-16f1440071f6 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 11:52:58 AM INFO 账户信息=9864909, 当前进程=10636, 当前进程的主进程=4728
+02/20/2021 11:53:09 AM INFO 策略uuid = f9cdc8b2-d26e-420b-895d-8863d9c709e9 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 11:53:53 AM INFO 账户信息=9864909, 当前进程=10636, 当前进程的主进程=4728
+02/20/2021 11:53:57 AM INFO 策略uuid = a7db5ce6-7f86-4140-8415-a2f018c0b73c 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 01:43:56 PM INFO 账户信息=9864909, 当前进程=3244, 当前进程的主进程=4728
+02/20/2021 01:43:59 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-20 13:43:56', 'account_id': 9864909, 'campaign_id': 35101081}, 'message': 'SUCCESS'}
+02/20/2021 01:43:59 PM INFO 广告计划创建成功,campaign_id = 35101081,  ai_strategy_uuid = 70ca1901-36bd-4188-8993-ad6b5fcde22c
+02/20/2021 01:44:02 PM INFO 策略uuid = 70ca1901-36bd-4188-8993-ad6b5fcde22c 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 01:45:20 PM INFO 账户信息=9864909, 当前进程=3244, 当前进程的主进程=4728
+02/20/2021 01:45:23 PM INFO the res of create campaign is {'code': 0, 'data': {'campaign_create_time': '2021-02-20 13:45:21', 'account_id': 9864909, 'campaign_id': 35101267}, 'message': 'SUCCESS'}
+02/20/2021 01:45:23 PM INFO 广告计划创建成功,campaign_id = 35101267,  ai_strategy_uuid = 35ddb6f3-33fa-4d64-b008-2ae690df89c0
+02/20/2021 01:45:27 PM INFO 策略uuid = 35ddb6f3-33fa-4d64-b008-2ae690df89c0 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 01:47:45 PM INFO 账户信息=9864909, 当前进程=4276, 当前进程的主进程=4728
+02/20/2021 01:47:51 PM INFO 策略uuid = 8bad8e08-6395-4629-b89d-d9d6483a42aa 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}
+02/20/2021 01:47:52 PM INFO 账户信息=9864909, 当前进程=4276, 当前进程的主进程=4728
+02/20/2021 01:48:01 PM INFO 策略uuid = 28305b60-1c7f-4d6f-b936-c0ed2dd09c7b 的请求返回信息:{'code': 0, 'message': '异步执行中,等待回调...'}

+ 15 - 0
logs/commonfunction.log

@@ -0,0 +1,15 @@
+02/20/2021 10:33:11 AM INFO common_function_logger started!
+02/20/2021 10:33:58 AM INFO account_id=9792538, app_version=None, the res of getNewVideoList is 暂未新上素材
+02/20/2021 11:09:33 AM INFO common_function_logger started!
+02/20/2021 11:09:45 AM INFO account_id=9864909, app_version=ksjymnnc15-模拟农场2015, the res of getHistoryTopVideoList is 暂未历史爆量素材
+02/20/2021 11:09:53 AM INFO account_id=9864909, app_version=ksjywzsjk-我做手机壳特好看, the res of getHistoryTopVideoList is 暂未历史爆量素材
+02/20/2021 11:40:49 AM INFO account_id=9864909, app_version=ksjydfnh-豆腐女孩, the res of getHistoryTopVideoList is 暂未历史爆量素材
+02/20/2021 11:43:47 AM INFO common_function_logger started!
+02/20/2021 11:51:28 AM INFO common_function_logger started!
+02/20/2021 11:53:47 AM INFO account_id=9864909, app_version=ksjydfnh-豆腐女孩, the res of getHistoryTopVideoList is 暂未历史爆量素材
+02/20/2021 01:41:07 PM INFO common_function_logger started!
+02/20/2021 01:43:35 PM INFO account_id=9864909, app_version=ksjyxdldl-新斗罗大陆, the res of getCreateZeroVideoList is 暂未关联创意数为0素材
+02/20/2021 01:45:08 PM INFO account_id=9864909, app_version=ksjyqljzs-桥梁建造师2, the res of getCreateZeroVideoList is 暂未关联创意数为0素材
+02/20/2021 01:47:27 PM INFO common_function_logger started!
+02/20/2021 01:47:45 PM INFO account_id=9864909, app_version=ksjyxdldl-新斗罗大陆, the res of getCreateZeroVideoList is 暂未关联创意数为0素材
+02/20/2021 01:47:52 PM INFO account_id=9864909, app_version=ksjyqljzs-桥梁建造师2, the res of getCreateZeroVideoList is 暂未关联创意数为0素材

+ 13 - 2
manual_request_json.py

@@ -22,8 +22,19 @@ def main():
     # print(res)
     # print(res)
 
 
     # data = json.dumps({"account_id": 23212})
     # data = json.dumps({"account_id": 23212})
-    data = json.dumps({"account_id": 9864904})
-    # url = 'http://192.168.1.193:31018/ai_programme_new_material'
+    # 手淘账号 9792538 登陆账号 16525664317  ai_historical_missing_material 联调测试通过
+    # 手淘账号 9792538 登陆账号 16525664317  ai_programme_high_quality_material 联调测试通过
+    # 手淘账号 9792538 登陆账号 16525664317  ai_auto_creative 联调测试通过
+    # 手淘账号 9792538 登陆账号 16525664317  ai_high_quality_material 联调测试通过
+
+    # data = json.dumps({"account_id": 9864909})
+    # 233账号 9864909 登陆账号 jy20201254@163.com   jysz12345 ai_high_quality_material  联调测试通过
+    # 233账号 9864909 登陆账号 jy20201254@163.com   jysz12345 ai_historical_missing_material  联调测试通过
+
+    data = json.dumps({"account_id": 9864909})
+    # url = 'http://192.168.1.193:31012/ai_auto_creative'
+    # url = 'http://192.168.1.193:31012/ai_high_quality_material'
+    # url = 'http://192.168.1.193:31012/ai_programme_new_material'
     # url = 'http://192.168.1.193:31012/ai_programme_high_quality_material'
     # url = 'http://192.168.1.193:31012/ai_programme_high_quality_material'
     url = 'http://192.168.1.193:31012/ai_historical_missing_material'
     url = 'http://192.168.1.193:31012/ai_historical_missing_material'
     request = requests.post(url, data)
     request = requests.post(url, data)

+ 1 - 2
time_task/time_task_ai_auto_creative.py

@@ -10,7 +10,7 @@ engine = create_engine(db_con_str, connect_args={'charset': 'utf8'})
 
 
 
 
 def send_request(account_id):
 def send_request(account_id):
-    url = 'http://139.186.27.96:31018/ai_auto_creative'
+    url = 'http://139.186.27.96:31012/ai_auto_creative'
     request_data = json.dumps({"account_id": account_id})
     request_data = json.dumps({"account_id": account_id})
     request = requests.post(url, request_data)
     request = requests.post(url, request_data)
     return json.loads(request.text)
     return json.loads(request.text)
@@ -26,7 +26,6 @@ select account_id from ctop_ai_kuaishou_advertiser_strategy where status = 1
 acc_df = pd.read_sql(sql, engine)
 acc_df = pd.read_sql(sql, engine)
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 print(acc_list)
 print(acc_list)
-acc_list = [9864909, 9864904, 9864899, 9864893, 9864888, 9863696]
 
 
 # 2、 5个账户一组进行发送请求
 # 2、 5个账户一组进行发送请求
 batch_num = 5
 batch_num = 5

+ 2 - 2
time_task/time_task_ai_check_and_up_to_full_creative.py

@@ -11,7 +11,7 @@ engine = create_engine(db_con_str, connect_args={'charset': 'utf8'})
 
 
 
 
 def send_request(account_id):
 def send_request(account_id):
-    url = 'http://139.186.27.96:31018/ai_check_and_up_to_full_creative'
+    url = 'http://139.186.27.96:31012/ai_check_and_up_to_full_creative'
     request_data = json.dumps({"account_id": account_id})
     request_data = json.dumps({"account_id": account_id})
     request = requests.post(url, request_data)
     request = requests.post(url, request_data)
     return json.loads(request.text)
     return json.loads(request.text)
@@ -27,7 +27,7 @@ select account_id from ctop_ai_kuaishou_advertiser_strategy where status = 1
 acc_df = pd.read_sql(sql, engine)
 acc_df = pd.read_sql(sql, engine)
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 print(acc_list)
 print(acc_list)
-acc_list = [9864909, 9864904, 9864899, 9864893, 9864888, 9863696]
+
 # 2、 5个账户一组进行发送请求
 # 2、 5个账户一组进行发送请求
 batch_num = 5
 batch_num = 5
 for i in range(0, len(acc_list), batch_num):
 for i in range(0, len(acc_list), batch_num):

+ 2 - 2
time_task/time_task_ai_high_quality_material.py

@@ -11,7 +11,7 @@ engine = create_engine(db_con_str, connect_args={'charset': 'utf8'})
 
 
 
 
 def send_request(account_id):
 def send_request(account_id):
-    url = 'http://139.186.27.96:31018/ai_high_quality_material'
+    url = 'http://139.186.27.96:31012/ai_high_quality_material'
     request_data = json.dumps({"account_id": account_id})
     request_data = json.dumps({"account_id": account_id})
     request = requests.post(url, request_data)
     request = requests.post(url, request_data)
     return json.loads(request.text)
     return json.loads(request.text)
@@ -27,7 +27,7 @@ select account_id from ctop_ai_kuaishou_advertiser_strategy where status = 1
 acc_df = pd.read_sql(sql, engine)
 acc_df = pd.read_sql(sql, engine)
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 print(acc_list)
 print(acc_list)
-acc_list = [9864909, 9864904, 9864899, 9864893, 9864888, 9863696]
+
 # 2、 5个账户一组进行发送请求
 # 2、 5个账户一组进行发送请求
 batch_num = 5
 batch_num = 5
 for i in range(0, len(acc_list), batch_num):
 for i in range(0, len(acc_list), batch_num):

+ 2 - 3
time_task/time_task_ai_historical_missing_material.py

@@ -11,7 +11,7 @@ engine = create_engine(db_con_str, connect_args={'charset': 'utf8'})
 
 
 
 
 def send_request(account_id):
 def send_request(account_id):
-    url = 'http://139.186.27.96:31018/ai_historical_missing_material'
+    url = 'http://139.186.27.96:31012/ai_historical_missing_material'
     request_data = json.dumps({"account_id": account_id})
     request_data = json.dumps({"account_id": account_id})
     request = requests.post(url, request_data)
     request = requests.post(url, request_data)
     return json.loads(request.text)
     return json.loads(request.text)
@@ -28,8 +28,7 @@ select account_id from ctop_ai_kuaishou_advertiser_strategy where status = 1
 acc_df = pd.read_sql(sql, engine)
 acc_df = pd.read_sql(sql, engine)
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 print(acc_list)
 print(acc_list)
-# acc_list = [9864909, 9864904, 9864899, 9864893, 9864888, 9863696]
-acc_list = [9863696]
+
 # 2、 5个账户一组进行发送请求
 # 2、 5个账户一组进行发送请求
 batch_num = 5
 batch_num = 5
 for i in range(0, len(acc_list), batch_num):
 for i in range(0, len(acc_list), batch_num):

+ 2 - 2
time_task/time_task_ai_program_creative_high_quality_materials.py

@@ -10,7 +10,7 @@ engine = create_engine(db_con_str, connect_args={'charset': 'utf8'})
 
 
 
 
 def send_request(account_id):
 def send_request(account_id):
-    url = 'http://139.186.27.96:31018/ai_programme_high_quality_material'
+    url = 'http://139.186.27.96:31012/ai_programme_high_quality_material'
     request_data = json.dumps({"account_id": account_id})
     request_data = json.dumps({"account_id": account_id})
     request = requests.post(url, request_data)
     request = requests.post(url, request_data)
     return json.loads(request.text)
     return json.loads(request.text)
@@ -26,7 +26,7 @@ select account_id from ctop_ai_kuaishou_advertiser_strategy where status = 1
 acc_df = pd.read_sql(sql, engine)
 acc_df = pd.read_sql(sql, engine)
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 print(acc_list)
 print(acc_list)
-acc_list = [9864909, 9864904, 9864899, 9864893, 9864888, 9863696]
+
 # 2、 5个账户一组进行发送请求
 # 2、 5个账户一组进行发送请求
 batch_num = 5
 batch_num = 5
 for i in range(0, len(acc_list), batch_num):
 for i in range(0, len(acc_list), batch_num):

+ 2 - 2
time_task/time_task_ai_program_creative_new_materials.py

@@ -10,7 +10,7 @@ engine = create_engine(db_con_str, connect_args={'charset': 'utf8'})
 
 
 
 
 def send_request(account_id):
 def send_request(account_id):
-    url = 'http://139.186.27.96:31018/ai_programme_new_material'
+    url = 'http://139.186.27.96:31012/ai_programme_new_material'
     request_data = json.dumps({"account_id": account_id})
     request_data = json.dumps({"account_id": account_id})
     request = requests.post(url, request_data)
     request = requests.post(url, request_data)
     return json.loads(request.text)
     return json.loads(request.text)
@@ -26,7 +26,7 @@ select account_id from ctop_ai_kuaishou_advertiser_strategy where status = 1
 acc_df = pd.read_sql(sql, engine)
 acc_df = pd.read_sql(sql, engine)
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
 print(acc_list)
 print(acc_list)
-acc_list = [9864909, 9864904, 9864899, 9864893, 9864888, 9863696]
+
 
 
 # 2、 5个账户一组进行发送请求
 # 2、 5个账户一组进行发送请求
 batch_num = 5
 batch_num = 5

+ 11 - 1
utils/CommonFunction.py

@@ -4,8 +4,18 @@ import json
 import pandas as pd
 import pandas as pd
 import datetime
 import datetime
 from utils.DataBaseConfig import *
 from utils.DataBaseConfig import *
-from ai_time_task_creative_handler import logger
 import traceback
 import traceback
+from concurrent_log import ConcurrentTimedRotatingFileHandler
+import logging
+
+log_formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s', '%m/%d/%Y %I:%M:%S %p')
+log_handler = ConcurrentTimedRotatingFileHandler("logs/commonfunction.log", when="midnight", backupCount=100)
+log_handler.setFormatter(log_formatter)
+logger = logging.getLogger('common_function_logger')
+logger.addHandler(log_handler)
+logger.setLevel(logging.DEBUG)
+print('id of common_function_logger %s' % id(logger))
+logger.info("common_function_logger started!")
 
 
 
 
 def get_lower_case_name(name):
 def get_lower_case_name(name):

+ 12 - 0
utils/ConstantConfig.py

@@ -10,12 +10,18 @@ if os_env_code_status == 'dev':
     high_quality_video_days = 140
     high_quality_video_days = 140
     high_quality_video_cnt = 2
     high_quality_video_cnt = 2
 
 
+    # 对于多应用使用多少个app_id对应高质量视频
+    high_quality_video_app_id = 2
+
     # 遗漏视频的开始时间  和 结束时间
     # 遗漏视频的开始时间  和 结束时间
     missing_video_start_time = (datetime.datetime.now() + datetime.timedelta(days=-60)).strftime("%Y-%m-%d")
     missing_video_start_time = (datetime.datetime.now() + datetime.timedelta(days=-60)).strftime("%Y-%m-%d")
     missing_video_end_time = str(datetime.date.today())
     missing_video_end_time = str(datetime.date.today())
     # 补充历史遗漏素材的个数
     # 补充历史遗漏素材的个数
     missing_video_cnt = 2
     missing_video_cnt = 2
 
 
+    # 对于多应用使用多少个app_id对应补充历史遗漏素材
+    missing_video_app_id = 2
+
     # 程序化创意跑量视频个数
     # 程序化创意跑量视频个数
     programme_high_quality_video_cnt = 13
     programme_high_quality_video_cnt = 13
     # 程序化创意上新视频个数
     # 程序化创意上新视频个数
@@ -29,12 +35,18 @@ else:
     high_quality_video_days = 14
     high_quality_video_days = 14
     high_quality_video_cnt = 100
     high_quality_video_cnt = 100
 
 
+    # 对于多应用使用多少个app_id对应高质量视频
+    high_quality_video_app_id = 100
+
     # 遗漏视频的开始时间  和 结束时间
     # 遗漏视频的开始时间  和 结束时间
     missing_video_start_time = (datetime.datetime.now() + datetime.timedelta(days=-60)).strftime("%Y-%m-%d %H:%M:%S")
     missing_video_start_time = (datetime.datetime.now() + datetime.timedelta(days=-60)).strftime("%Y-%m-%d %H:%M:%S")
     missing_video_end_time = datetime.date.today().strftime("%Y-%m-%d %H:%M:%S")
     missing_video_end_time = datetime.date.today().strftime("%Y-%m-%d %H:%M:%S")
     # 补充历史遗落素材的个数
     # 补充历史遗落素材的个数
     missing_video_cnt = 100
     missing_video_cnt = 100
 
 
+    # 对于多应用使用多少个app_id对应补充历史遗漏素材
+    missing_video_app_id = 100
+
     # 程序化创意跑量视频个数
     # 程序化创意跑量视频个数
     programme_high_quality_video_cnt = 150
     programme_high_quality_video_cnt = 150
     # 程序化创意上新视频个数
     # 程序化创意上新视频个数