add log

app.py

@@ -39,6 +39,12 @@ def homepage_recommend():
     try:
         request_data = json.loads(request.get_data())
         request_id = request_data.get('requestId')
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': request_id,
+            'text': 'in homepage_recommend',
+            'executeTime': (time.time() - start_time) * 1000
+        })
         mid = request_data.get('mid')
         uid = request_data.get('uid')
         category_id = request_data.get('categoryId')
@@ -60,14 +66,17 @@ def homepage_recommend():
                                               algo_type=algo_type, client_info=client_info,
                                               ab_exp_info=ab_exp_info, params=params)
             result = {'code': 200, 'message': 'success', 'data': {'videos': videos}}
-            log_.info({'requestUri': '/applet/video/homepage/recommend',
-                       'request_id': request_id,
-                       'app_type': app_type,
-                       'category_id': category_id,
-                       'mid': mid,
-                       'uid': uid,
-                       'result': result,
-                       'executeTime': (time.time() - start_time) * 1000})
+            log_.info({
+                'requestUri': '/applet/video/homepage/recommend',
+                'logTimestamp': int(time.time() * 1000),
+                'request_id': request_id,
+                'app_type': app_type,
+                'category_id': category_id,
+                'mid': mid,
+                'uid': uid,
+                'result': result,
+                'executeTime': (time.time() - start_time) * 1000
+            })
             # log_.info('category_id: {}, mid: {}, uid: {}, result: {}, execute time = {}ms'.format(
             #     category_id, mid, uid, result, (time.time() - start_time)*1000))
             return json.dumps(result)
@@ -96,13 +105,19 @@ def relevant_recommend():
     try:
         request_data = json.loads(request.get_data())
         request_id = request_data.get('requestId')
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': request_id,
+            'text': 'in relevant_recommend',
+            'executeTime': (time.time() - start_time) * 1000
+        })
         mid = request_data.get('mid')
         uid = request_data.get('uid')
         video_id = request_data.get('videoId')
-        up_uid = request_data.get('upUid')
-        share_mid = request_data.get('shareMid')
-        share_uid = request_data.get('shareUid')
-        page_num = request_data.get('pageNum', 1)
+        # up_uid = request_data.get('upUid')
+        # share_mid = request_data.get('shareMid')
+        # share_uid = request_data.get('shareUid')
+        # page_num = request_data.get('pageNum', 1)
         page_size = request_data.get('pageSize', 4)
         app_type = request_data.get('appType')
         client_info = request_data.get('clientInfo')
@@ -120,13 +135,16 @@ def relevant_recommend():
                                           params=params)
 
         result = {'code': 200, 'message': 'success', 'data': {'videos': videos}}
-        log_.info({'requestUri': '/applet/video/relevant/recommend',
-                   'request_id': request_id,
-                   'app_type': app_type,
-                   'mid': mid,
-                   'uid': uid,
-                   'result': result,
-                   'executeTime': (time.time() - start_time) * 1000})
+        log_.info({
+            'requestUri': '/applet/video/relevant/recommend',
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': request_id,
+            'app_type': app_type,
+            'mid': mid,
+            'uid': uid,
+            'result': result,
+            'executeTime': (time.time() - start_time) * 1000
+        })
 
         # log_.info('app_type: {}, mid: {}, uid: {}, relevant-result: {}, execute time = {}ms'.format(
         #     app_type, mid, uid, result, (time.time() - start_time) * 1000))
@@ -143,7 +161,9 @@ def update_rov():
     try:
         # log_.info({'requestUri': '/applet/video/update/rov', 'request_initial': request.get_data()})
         request_data = json.loads(request.get_data())
-        log_.info({'requestUri': '/applet/video/update/rov', 'requestData': request_data})
+        log_.info({'requestUri': '/applet/video/update/rov',
+                   'logTimestamp': int(time.time() * 1000),
+                   'requestData': request_data})
         # log_.info('update_rov request data: {}'.format(request_data))
         # app_type = request_data.get('appType')
         video_id = request_data.get('videoId')
@@ -158,7 +178,7 @@ def update_rov():
         # update_video_w_h_rate(video_id=int(video_id), key_name=config_.W_H_RATE_UP_1_VIDEO_LIST_KEY_NAME['rov_recall'])
 
         result = {'code': 200, 'message': 'update rov success'}
-        log_.info({'requestUri': '/applet/video/update/rov', 'result': result})
+        log_.info({'requestUri': '/applet/video/update/rov', 'logTimestamp': int(time.time() * 1000), 'result': result})
         # log_.info('result: {}'.format(result))
         return json.dumps(result)
     except Exception as e:

db_helper.py

@@ -49,10 +49,13 @@ class RedisHelper(object):
         start_time = time.time()
         conn = self.connect()
         res = conn.exists(key_name)
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'get_data_from_redis',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'get_data_from_redis',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
         return res
 
     def del_keys(self, key_name):
@@ -76,10 +79,13 @@ class RedisHelper(object):
             # key不存在
             return None
         data = conn.get(key_name)
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'get_data_from_redis',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'get_data_from_redis',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
         return data
 
     def set_data_to_redis(self, key_name, value, expire_time=24*3600):
@@ -93,10 +99,12 @@ class RedisHelper(object):
         start_time = time.time()
         conn = self.connect()
         conn.set(key_name, value, ex=int(expire_time))
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'set_data_to_redis',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'set_data_to_redis',
+        #         'executeTime': (time.time() - start_time) * 1000})
 
     def add_data_with_zset(self, key_name, data, expire_time=7*24*3600):
         """
@@ -111,10 +119,13 @@ class RedisHelper(object):
         conn.zadd(key_name, data)
         # 设置过期时间
         conn.expire(key_name, int(expire_time))
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'add_data_with_zset',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'add_data_with_zset',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
 
     def get_data_zset_with_index(self, key_name, start, end, desc=True, with_scores=False):
         """
@@ -136,10 +147,13 @@ class RedisHelper(object):
         else:
             data = [eval(value) for value in data]
 
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'get_data_zset_with_index',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'get_data_zset_with_index',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
         return data
 
     def get_score_with_value(self, key_name, value):
@@ -180,10 +194,13 @@ class RedisHelper(object):
         start_time = time.time()
         conn = self.connect()
         conn.zrem(key_name, value)
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'remove_value_from_zset',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'remove_value_from_zset',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
 
     def get_index_with_data(self, key_name, value):
         """
@@ -195,10 +212,13 @@ class RedisHelper(object):
         start_time = time.time()
         conn = self.connect()
         res = conn.zrevrank(key_name, value)
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'get_index_with_data',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'get_index_with_data',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
         return res
 
     def get_data_from_set(self, key_name):
@@ -221,10 +241,13 @@ class RedisHelper(object):
                 break
             cursor = cur
 
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'get_data_from_set',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'get_data_from_set',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
         return list(set(data))
 
     def add_data_with_set(self, key_name, values, expire_time=30*60):
@@ -240,10 +263,13 @@ class RedisHelper(object):
         conn.sadd(key_name, *values)
         # 设置过期时间
         conn.expire(key_name, int(expire_time))
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'add_data_with_set',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'add_data_with_set',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
 
     def data_exists_with_set(self, key_name, value):
         """
@@ -255,10 +281,13 @@ class RedisHelper(object):
         start_time = time.time()
         conn = self.connect()
         res = conn.sismember(key_name, value)
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'data_exists_with_set',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'data_exists_with_set',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
         return res
 
     def remove_value_from_set(self, key_name, values):
@@ -271,10 +300,13 @@ class RedisHelper(object):
         start_time = time.time()
         conn = self.connect()
         conn.srem(key_name, *values)
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'remove_value_from_set',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'remove_value_from_set',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
 
     def decr_key(self, key_name, amount=1, expire_time=30*60):
         """
@@ -288,10 +320,13 @@ class RedisHelper(object):
         conn = self.connect()
         conn.decr(name=key_name, amount=amount)
         conn.expire(key_name, int(expire_time))
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'decr_key',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'decr_key',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
 
     def incr_key(self, key_name, amount=1, expire_time=30*60):
         """
@@ -305,10 +340,13 @@ class RedisHelper(object):
         conn = self.connect()
         conn.incr(name=key_name, amount=amount)
         conn.expire(key_name, int(expire_time))
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'incr_key',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'incr_key',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
 
     def setnx_key(self, key_name, value, expire_time=5*60):
         """
@@ -321,10 +359,13 @@ class RedisHelper(object):
         conn = self.connect()
         conn.setnx(name=key_name, value=value)
         conn.expire(name=key_name, time=int(expire_time))
-        if self.params is not None:
-            log_.info({'request_id': self.params.request_id,
-                       'operation': 'setnx_key',
-                       'executeTime': (time.time() - start_time) * 1000})
+        # if self.params is not None:
+        #     log_.info({
+        #         'logTimestamp': int(time.time() * 1000),
+        #         'request_id': self.params.request_id,
+        #         'operation': 'setnx_key',
+        #         'executeTime': (time.time() - start_time) * 1000
+        #     })
 
 
 #hologres_info = config_.HOLOGRES_INFO

recommend.py

@@ -218,13 +218,16 @@ def video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type, al
     gevent.joinall(t)
     recall_result_list = [i.get() for i in t]
 
-    end_recall = time.time()
-    log_.info({'request_id': request_id,
-               'mid': mid,
-               'uid': uid,
-               'operation': 'recall',
-               'recall_result': recall_result_list,
-               'executeTime': (end_recall - start_recall) * 1000})
+    # end_recall = time.time()
+    log_.info({
+        'logTimestamp': int(time.time() * 1000),
+        'request_id': request_id,
+        'mid': mid,
+        'uid': uid,
+        'operation': 'recall',
+        'recall_result': recall_result_list,
+        'executeTime': (time.time() - start_recall) * 1000
+    })
 
 
     # ####### 排序
@@ -257,26 +260,32 @@ def video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type, al
     #     rank_result = video_rank_with_old_video(rank_result=rank_result, old_video_recall=recall_result_list[2],
     #                                             size=size, top_K=top_K, old_video_index=old_video_index)
 
-    end_rank = time.time()
-    log_.info({'request_id': request_id,
-               'mid': mid,
-               'uid': uid,
-               'operation': 'rank',
-               'rank_result': rank_result,
-               'executeTime': (end_rank - start_rank) * 1000})
+    # end_rank = time.time()
+    log_.info({
+        'logTimestamp': int(time.time() * 1000),
+        'request_id': request_id,
+        'mid': mid,
+        'uid': uid,
+        'operation': 'rank',
+        'rank_result': rank_result,
+        'executeTime': (time.time() - start_rank) * 1000
+    })
 
     if not rank_result:
         # 兜底策略
         # log_.info('====== bottom strategy')
         start_bottom = time.time()
         rank_result = bottom_strategy(request_id=request_id, size=size, app_type=app_type, ab_code=ab_code, params=params)
-        end_bottom = time.time()
-        log_.info({'request_id': request_id,
-                   'mid': mid,
-                   'uid': uid,
-                   'operation': 'bottom',
-                   'bottom_result': rank_result,
-                   'executeTime': (end_bottom - start_bottom) * 1000})
+        # end_bottom = time.time()
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': request_id,
+            'mid': mid,
+            'uid': uid,
+            'operation': 'bottom',
+            'bottom_result': rank_result,
+            'executeTime': (time.time() - start_bottom) * 1000
+        })
 
     return rank_result, last_rov_recall_key
 
@@ -622,12 +631,15 @@ def video_homepage_recommend(request_id, mid, uid, size, app_type, algo_type, cl
         param_st = time.time()
         top_K, flow_pool_P, ab_code, rule_key, expire_time, no_op_flag, old_video_index = \
             get_recommend_params(ab_exp_info=ab_exp_info)
-        log_.info({'request_id': request_id,
-                   'app_type': app_type,
-                   'mid': mid,
-                   'uid': uid,
-                   'operation': 'get_recommend_params',
-                   'executeTime': (time.time() - param_st) * 1000})
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': request_id,
+            'app_type': app_type,
+            'mid': mid,
+            'uid': uid,
+            'operation': 'get_recommend_params',
+            'executeTime': (time.time() - param_st) * 1000
+        })
 
         # 简单召回 - 排序 - 兜底
         get_result_st = time.time()
@@ -639,12 +651,15 @@ def video_homepage_recommend(request_id, mid, uid, size, app_type, algo_type, cl
                                                            rule_key=rule_key, no_op_flag=no_op_flag,
                                                            old_video_index=old_video_index,
                                                            params=params)
-        log_.info({'request_id': request_id,
-                   'app_type': app_type,
-                   'mid': mid,
-                   'uid': uid,
-                   'operation': 'get_recommend_result',
-                   'executeTime': (time.time() - get_result_st) * 1000})
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': request_id,
+            'app_type': app_type,
+            'mid': mid,
+            'uid': uid,
+            'operation': 'get_recommend_result',
+            'executeTime': (time.time() - get_result_st) * 1000
+        })
 
         # ab-test
         # result = ab_test_op(rank_result=rank_result,
@@ -654,12 +669,15 @@ def video_homepage_recommend(request_id, mid, uid, size, app_type, algo_type, cl
         update_redis_st = time.time()
         update_redis_data(result=rank_result, app_type=app_type, mid=mid, last_rov_recall_key=last_rov_recall_key,
                           top_K=top_K)
-        log_.info({'request_id': request_id,
-                   'app_type': app_type,
-                   'mid': mid,
-                   'uid': uid,
-                   'operation': 'update_redis_data',
-                   'executeTime': (time.time() - update_redis_st) * 1000})
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': request_id,
+            'app_type': app_type,
+            'mid': mid,
+            'uid': uid,
+            'operation': 'update_redis_data',
+            'executeTime': (time.time() - update_redis_st) * 1000
+        })
 
     return rank_result
 
@@ -682,12 +700,15 @@ def video_relevant_recommend(request_id, video_id, mid, uid, size, app_type, ab_
     param_st = time.time()
     top_K, flow_pool_P, ab_code, rule_key, expire_time, no_op_flag, old_video_index = \
         get_recommend_params(ab_exp_info=ab_exp_info, page_type=page_type)
-    log_.info({'request_id': request_id,
-               'app_type': app_type,
-               'mid': mid,
-               'uid': uid,
-               'operation': 'get_recommend_params',
-               'executeTime': (time.time() - param_st) * 1000})
+    log_.info({
+        'logTimestamp': int(time.time() * 1000),
+        'request_id': request_id,
+        'app_type': app_type,
+        'mid': mid,
+        'uid': uid,
+        'operation': 'get_recommend_params',
+        'executeTime': (time.time() - param_st) * 1000
+    })
 
     # 简单召回 - 排序 - 兜底
     get_result_st = time.time()
@@ -699,12 +720,15 @@ def video_relevant_recommend(request_id, video_id, mid, uid, size, app_type, ab_
                                                        rule_key=rule_key, no_op_flag=no_op_flag,
                                                        old_video_index=old_video_index, video_id=video_id,
                                                        params=params)
-    log_.info({'request_id': request_id,
-               'app_type': app_type,
-               'mid': mid,
-               'uid': uid,
-               'operation': 'get_recommend_result',
-               'executeTime': (time.time() - get_result_st) * 1000})
+    log_.info({
+        'logTimestamp': int(time.time() * 1000),
+        'request_id': request_id,
+        'app_type': app_type,
+        'mid': mid,
+        'uid': uid,
+        'operation': 'get_recommend_result',
+        'executeTime': (time.time() - get_result_st) * 1000
+    })
     # ab-test
     # result = ab_test_op(rank_result=rank_result,
     #                     ab_code_list=[config_.AB_CODE['position_insert'], config_.AB_CODE['relevant_video_op']],
@@ -714,12 +738,15 @@ def video_relevant_recommend(request_id, video_id, mid, uid, size, app_type, ab_
     update_redis_st = time.time()
     update_redis_data(result=rank_result, app_type=app_type, mid=mid, last_rov_recall_key=last_rov_recall_key,
                       top_K=top_K)
-    log_.info({'request_id': request_id,
-               'app_type': app_type,
-               'mid': mid,
-               'uid': uid,
-               'operation': 'update_redis_data',
-               'executeTime': (time.time() - update_redis_st) * 1000})
+    log_.info({
+        'logTimestamp': int(time.time() * 1000),
+        'request_id': request_id,
+        'app_type': app_type,
+        'mid': mid,
+        'uid': uid,
+        'operation': 'update_redis_data',
+        'executeTime': (time.time() - update_redis_st) * 1000
+    })
 
     return rank_result
 

video_recall.py

@@ -186,7 +186,7 @@ class PoolRecall(object):
                                                                   start=(freq - 1) * get_size, end=freq * get_size - 1,
                                                                   with_scores=True)
                 if not data:
-                    log_.info('小时级更新视频已取完')
+                    # log_.info('小时级更新视频已取完')
                     break
                 # 获取视频id,并转换类型为int,并存储为key-value{videoId: score}
                 video_ids = []
@@ -244,7 +244,7 @@ class PoolRecall(object):
         rule_key_name, last_rule_day_recall_key, idx = self.get_video_last_idx_day()
         # 获取天级规则更新列表数据
         if not rule_key_name:
-            log_.info('天级规则更新列表中无视频')
+            # log_.info('天级规则更新列表中无视频')
             recall_result = self.rov_pool_recall(size=size, expire_time=expire_time)
         else:
             recall_result = []
@@ -261,7 +261,7 @@ class PoolRecall(object):
                                                                   start=idx, end=idx + get_size - 1,
                                                                   with_scores=True)
                 if not data:
-                    log_.info('天级规则更新视频已取完')
+                    # log_.info('天级规则更新视频已取完')
                     break
                 # 获取视频id,并转换类型为int,并存储为key-value{videoId: score}
                 video_ids = []
@@ -343,7 +343,7 @@ class PoolRecall(object):
         # 获取相关redis key, 用户上一次在rov召回池对应的位置
         rov_pool_key, last_rov_recall_key, idx = self.get_video_last_idx(video_type=video_type)
         if not rov_pool_key:
-            log_.info('ROV召回池中无视频')
+            # log_.info('ROV召回池中无视频')
             if (not update_rov_dup_result) and (not top_video_result):
                 return []
             rov_pool_recall_result = top_video_result.extend(update_rov_dup_result)
@@ -367,7 +367,7 @@ class PoolRecall(object):
             # log_.info('get data from rov pool redis: freq = {}, data = {}, execute time = {}ms'.format(
             #     freq, data, (et_get - st_get) * 1000))
             if not data:
-                log_.info('ROV召回池中的视频已取完')
+                # log_.info('ROV召回池中的视频已取完')
                 break
             # 获取视频id,并转换类型为int,并存储为key-value{videoId: score}
             video_ids = []
@@ -433,7 +433,7 @@ class PoolRecall(object):
             # log_.info('get data from flow pool redis: freq = {}, data = {}, execute time = {}ms'.format(
             #     freq, data, (et_get - st_get) * 1000))
             if not data:
-                log_.info('流量池中的视频已取完')
+                # log_.info('流量池中的视频已取完')
                 break
             # 将video_id 与 flow_pool, score做mapping整理
             video_ids = []
@@ -543,7 +543,7 @@ class PoolRecall(object):
                 # 接口超时，item[2]可能为None
                 remain_count = int(item[2])
             except Exception as e:
-                log_.error('remain_count type error...')
+                # log_.error('remain_count type error...')
                 log_.error(traceback.format_exc())
                 continue
             if remain_count > 0:
@@ -896,7 +896,7 @@ class PoolRecall(object):
             return config_.FLOW_POOL_KEY_NAME_PREFIX + str(self.app_type)
 
         else:
-            log_.error('pool type error')
+            # log_.error('pool type error')
             return None, None
 
     def flow_pool_recall_18_19(self, size=4, push_from=config_.PUSH_FROM['flow_recall']):
@@ -921,7 +921,7 @@ class PoolRecall(object):
             # log_.info('get data from flow pool redis: freq = {}, data = {}, execute time = {}ms'.format(
             #     freq, data, (et_get - st_get) * 1000))
             if not data:
-                log_.info('流量池中的视频已取完')
+                # log_.info('流量池中的视频已取完')
                 break
             # 将video_id 与 score做mapping整理
             video_ids = []
@@ -990,7 +990,7 @@ class PoolRecall(object):
             return config_.FLOW_POOL_KEY_NAME_PREFIX + str(self.app_type)
 
         else:
-            log_.error('pool type error')
+            # log_.error('pool type error')
             return None, None
 
     def get_video_last_idx_day(self):
@@ -1181,7 +1181,7 @@ class PoolRecall(object):
                                                                   start=(freq - 1) * get_size, end=freq * get_size - 1,
                                                                   with_scores=True)
                 if not data:
-                    log_.info('地域分组小时级更新视频已取完')
+                    # log_.info('地域分组小时级更新视频已取完')
                     break
                 # 获取视频id,并转换类型为int,并存储为key-value{videoId: score}
                 video_ids = []
@@ -1231,7 +1231,7 @@ class PoolRecall(object):
             province_code=province_code, region_dup=region_dup)
         # 获取天级规则更新列表数据
         if not key_name:
-            log_.info(f'region dup 更新列表中无视频, region_dup = {region_dup}')
+            # log_.info(f'region dup 更新列表中无视频, region_dup = {region_dup}')
             recall_result = []
         else:
             recall_result = []
@@ -1248,7 +1248,7 @@ class PoolRecall(object):
                                                                   start=idx, end=idx + get_size - 1,
                                                                   with_scores=True)
                 if not data:
-                    log_.info(f'region dup 更新视频已取完, region_dup = {region_dup}')
+                    # log_.info(f'region dup 更新视频已取完, region_dup = {region_dup}')
                     break
                 # 获取视频id,并转换类型为int,并存储为key-value{videoId: score}
                 video_ids = []
@@ -1353,7 +1353,7 @@ class PoolRecall(object):
                                                                   start=(freq - 1) * get_size, end=freq * get_size - 1,
                                                                   with_scores=True)
                 if not data:
-                    log_.info('小时级更新视频已取完')
+                    # log_.info('小时级更新视频已取完')
                     break
                 # 获取视频id,并转换类型为int,并存储为key-value{videoId: score}
                 video_ids = []