add log

video_recall.py

@@ -1692,7 +1692,8 @@ class PoolRecall(object):
         :return:
         """
         start_time = time.time()
-        log_.info(f"key_flag = {key_flag}")
+        log_.info({'request_id': self.request_id,
+                   'key_flag': key_flag})
         if key_flag == '24h_dup2':
             # 不分地域相对24h的筛选结果
             # mid对应上一次视频位置 时间记录
@@ -1714,6 +1715,10 @@ class PoolRecall(object):
         pool_key, idx = self.get_last_recommend_video_idx(province_code=province_code,
                                                           record_key_prefix=record_key_prefix,
                                                           pool_key_prefix=pool_key_prefix)
+        log_.info({'request_id': self.request_id,
+                   'key_flag': key_flag,
+                   'pool_key': pool_key,
+                   'idx': idx})
         if not pool_key:
             return []
         pool_recall_result = []
@@ -1729,6 +1734,11 @@ class PoolRecall(object):
             data = self.redis_helper.get_data_zset_with_index(key_name=pool_key,
                                                               start=idx, end=idx + get_size - 1,
                                                               with_scores=True)
+            log_.info({'request_id': self.request_id,
+                       'key_flag': key_flag,
+                       'pool_key': pool_key,
+                       'idx': idx,
+                       'data': data})
             if not data:
                 break
             # 获取视频id,并转换类型为int,并存储为key-value{videoId: score}