浏览代码

日志信息中添加当前进程id和主进程id

liyuyi@c-top.com.cn 4 年之前
父节点
当前提交
99bb1493bd
共有 3 个文件被更改,包括 17 次插入17 次删除
  1. 2 3
      ai_strategy_request_func.py
  2. 13 12
      ai_time_task_creative_handler.py
  3. 2 2
      utils/ConstantConfig.py

+ 2 - 3
ai_strategy_request_func.py

@@ -7,6 +7,7 @@ import pandas as pd
 import pymysql
 import requests
 from utils.BaseClass import *
+import os
 from utils.DataBaseConfig import *
 from utils.LogConfig import *
 from utils.UrlConfig import *
@@ -29,6 +30,7 @@ def ai_strategy_request_parse(data):
     print(data)
     if data["operation_type"] == 1:
         inst = ParseAddCampaignOrAddGroupRequest(data)
+        logger.info("账户信息=%s, 当前进程=%s, 当前进程的主进程=%s" % (inst.account_id, os.getpid(), os.getppid()))
         # 1 获取客户策略信息
         inst.get_advertiser_strategy_info()
 
@@ -115,10 +117,7 @@ class ParseAddCampaignOrAddGroupRequest(object):
                 'create_time': datetime.datetime.now()
             }
         df = pd.DataFrame.from_dict(intelligence_strategy_dict, orient='index').T
-        print(df.dtypes)
-        print("$$$$$$$$$$$$$")
         df.to_sql(name="ctop_ai_kuaishou_intelligence_strategy", con=engine, if_exists='append', index=False)
-        print("^^^^^^^^^^^^^^^^^^^^")
 
     def update_intelligence_strategy_table(self, request_content=None, message=None):
         """

+ 13 - 12
ai_time_task_creative_handler.py

@@ -30,10 +30,10 @@ class AiHistoricalMissingMaterial(tornado.web.RequestHandler):
         data = str(data, 'utf8')
         data = json.loads(data, encoding='utf8')
         logger.info("***************************************  NEW REQUEST ***************************************")
-        logger.info("raw data from request is %s" % data)
-
         account_id = data.get('account_id')
         campaign_id = data.get('campaign_id')
+        logger.info("账户信息=%s, 当前进程=%s, 当前进程的主进程=%s,  raw data from request is %s" %
+                    (account_id, os.getpid(), os.getppid(), data))
         try:
             video_info = get_missing_video_info(account_id,
                                                 missing_video_cnt,
@@ -78,10 +78,10 @@ class AiAutoCreative(tornado.web.RequestHandler):
         data = str(data, 'utf8')
         data = json.loads(data, encoding='utf8')
         logger.info("***************************************  NEW REQUEST ***************************************")
-        logger.info("raw data from request is %s" % data)
-
         account_id = data.get('account_id')
         campaign_id = data.get('campaign_id')
+        logger.info("账户信息=%s, 当前进程=%s, 当前进程的主进程=%s,  raw data from request is %s" %
+                    (account_id, os.getpid(), os.getppid(), data))
         try:
             start_time = (datetime.date.today()).strftime('%Y-%m-%d %H:%M:%S')
             end_time = (datetime.datetime.now()).strftime('%Y-%m-%d %H:%M:%S')
@@ -138,10 +138,10 @@ class AiHighQualityMaterial(tornado.web.RequestHandler):
         data = str(data, 'utf8')
         data = json.loads(data, encoding='utf8')
         logger.info("***************************************  NEW REQUEST ***************************************")
-        logger.info("raw data from request is %s" % data)
-
         account_id = data.get('account_id')
         campaign_id = data.get('campaign_id')
+        logger.info("账户信息=%s, 当前进程=%s, 当前进程的主进程=%s,  raw data from request is %s" %
+                    (account_id, os.getpid(), os.getppid(), data))
         try:
             video_info = get_top_video_info(account_id, high_quality_video_cnt,
                                             (datetime.datetime.now() + datetime.timedelta(days=-high_quality_video_days)).strftime("%Y-%m-%d"),
@@ -187,10 +187,11 @@ class AiCheckAndUpTOFullCreative(tornado.web.RequestHandler):
         data = str(data, 'utf8')
         data = json.loads(data, encoding='utf8')
         logger.info("***************************************  NEW REQUEST ***************************************")
-        logger.info("raw data from request is %s" % data)
-
         account_id = data.get('account_id')
         campaign_id = data.get('campaign_id')
+
+        logger.info("账户信息=%s, 当前进程=%s, 当前进程的主进程=%s,  raw data from request is %s" %
+                    (account_id, os.getpid(), os.getppid(), data))
         try:
             start_time = (datetime.date.today()).strftime('%Y-%m-%d %H:%M:%S')
             end_time = (datetime.datetime.now()).strftime('%Y-%m-%d %H:%M:%S')
@@ -303,10 +304,10 @@ class AiProgramCreativeHighQualityMaterial(tornado.web.RequestHandler):
         data = str(data, 'utf8')
         data = json.loads(data, encoding='utf8')
         logger.info("***************************************  NEW REQUEST ***************************************")
-        logger.info("raw data from request is %s" % data)
-
         account_id = data.get('account_id')
         campaign_id = data.get('campaign_id')
+        logger.info("账户信息=%s, 当前进程=%s, 当前进程的主进程=%s,  raw data from request is %s" %
+                    (account_id, os.getpid(), os.getppid(), data))
 
         try:
             video_info = get_top_video_info(account_id, programme_high_quality_video_cnt,
@@ -354,10 +355,10 @@ class AiProgramCreativeNewMaterial(tornado.web.RequestHandler):
         data = str(data, 'utf8')
         data = json.loads(data, encoding='utf8')
         logger.info("***************************************  NEW REQUEST ***************************************")
-        logger.info("raw data from request is %s" % data)
-
         account_id = data.get('account_id')
         campaign_id = data.get('campaign_id')
+        logger.info("账户信息=%s, 当前进程=%s, 当前进程的主进程=%s,  raw data from request is %s" %
+                    (account_id, os.getpid(), os.getppid(), data))
 
         try:
             video_info = get_history_video_info(account_id=account_id,

+ 2 - 2
utils/ConstantConfig.py

@@ -36,9 +36,9 @@ else:
     missing_video_cnt = 100
 
     # 程序化创意跑量视频个数
-    programme_high_quality_video_cnt = 15
+    programme_high_quality_video_cnt = 150
     # 程序化创意上新视频个数
-    programme_new_video_cnt = 15
+    programme_new_video_cnt = 150
     # 调用获取历史视频接口时,关联的最大创意个数
     related_creative_max_cnt = 10