add log

utils.py

@@ -28,7 +28,7 @@ def send_msg_to_feishu(msg_text):
         }
     }
     response = requests.request('POST', url=webhook, headers=headers, data=json.dumps(payload_message))
-    print(response.text)
+    # print(response.text)
 
 
 def request_post(request_url, request_data, timeout):
@@ -180,15 +180,18 @@ class FilterVideos(object):
         # 预曝光过滤
         st_pre = time.time()
         filtered_pre_result = self.filter_video_previewed(self.video_ids)
-        et_pre = time.time()
-        log_.info({'request_id': self.request_id,
-                   'app_type': self.app_type,
-                   'mid': self.mid,
-                   'uid': self.uid,
-                   'operation': 'preview_filter',
-                   'request_videos': self.video_ids,
-                   'preview_filter_result': filtered_pre_result,
-                   'executeTime': (et_pre - st_pre) * 1000})
+        # et_pre = time.time()
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': self.request_id,
+            'app_type': self.app_type,
+            'mid': self.mid,
+            'uid': self.uid,
+            'operation': 'preview_filter',
+            'request_videos': self.video_ids,
+            'preview_filter_result': filtered_pre_result,
+            'executeTime': (time.time() - st_pre) * 1000
+        })
         if not filtered_pre_result:
             return None
 
@@ -197,30 +200,36 @@ class FilterVideos(object):
         filtered_status_result = self.filter_video_status_h(video_ids=filtered_pre_result, rule_key=rule_key,
                                                             ab_code=ab_code, province_code=province_code,
                                                             key_flag=key_flag)
-        et_status = time.time()
-        log_.info({'request_id': self.request_id,
-                   'app_type': self.app_type,
-                   'mid': self.mid,
-                   'uid': self.uid,
-                   'operation': 'status_filter',
-                   'request_videos': filtered_pre_result,
-                   'status_filter_result': filtered_status_result,
-                   'executeTime': (et_status - st_status) * 1000})
+        # et_status = time.time()
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': self.request_id,
+            'app_type': self.app_type,
+            'mid': self.mid,
+            'uid': self.uid,
+            'operation': 'status_filter',
+            'request_videos': filtered_pre_result,
+            'status_filter_result': filtered_status_result,
+            'executeTime': (time.time() - st_status) * 1000
+        })
         if not filtered_status_result:
             return None
 
         # 视频已曝光过滤
         st_viewed = time.time()
         filtered_viewed_result = self.filter_video_viewed(video_ids=filtered_status_result)
-        et_viewed = time.time()
-        log_.info({'request_id': self.request_id,
-                   'app_type': self.app_type,
-                   'mid': self.mid,
-                   'uid': self.uid,
-                   'operation': 'view_filter',
-                   'request_videos': filtered_status_result,
-                   'view_filter_result': filtered_viewed_result,
-                   'executeTime': (et_viewed - st_viewed) * 1000})
+        # et_viewed = time.time()
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': self.request_id,
+            'app_type': self.app_type,
+            'mid': self.mid,
+            'uid': self.uid,
+            'operation': 'view_filter',
+            'request_videos': filtered_status_result,
+            'view_filter_result': filtered_viewed_result,
+            'executeTime': (time.time() - st_viewed) * 1000
+        })
         if not filtered_viewed_result:
             return None
         else:
@@ -231,15 +240,18 @@ class FilterVideos(object):
         # 预曝光过滤
         st_pre = time.time()
         filtered_pre_result = self.filter_video_previewed(self.video_ids)
-        et_pre = time.time()
-        log_.info({'request_id': self.request_id,
-                   'app_type': self.app_type,
-                   'mid': self.mid,
-                   'uid': self.uid,
-                   'operation': 'preview_filter',
-                   'request_videos': self.video_ids,
-                   'preview_filter_result': filtered_pre_result,
-                   'executeTime': (et_pre - st_pre) * 1000})
+        # et_pre = time.time()
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': self.request_id,
+            'app_type': self.app_type,
+            'mid': self.mid,
+            'uid': self.uid,
+            'operation': 'preview_filter',
+            'request_videos': self.video_ids,
+            'preview_filter_result': filtered_pre_result,
+            'executeTime': (time.time() - st_pre) * 1000
+        })
         if not filtered_pre_result:
             return None
 
@@ -256,15 +268,18 @@ class FilterVideos(object):
         # 视频已曝光过滤
         st_viewed = time.time()
         filtered_viewed_result = self.filter_video_viewed(video_ids=filtered_pre_result)
-        et_viewed = time.time()
-        log_.info({'request_id': self.request_id,
-                   'app_type': self.app_type,
-                   'mid': self.mid,
-                   'uid': self.uid,
-                   'operation': 'view_filter',
-                   'request_videos': filtered_pre_result,
-                   'view_filter_result': filtered_viewed_result,
-                   'executeTime': (et_viewed - st_viewed) * 1000})
+        # et_viewed = time.time()
+        log_.info({
+            'logTimestamp': int(time.time() * 1000),
+            'request_id': self.request_id,
+            'app_type': self.app_type,
+            'mid': self.mid,
+            'uid': self.uid,
+            'operation': 'view_filter',
+            'request_videos': filtered_pre_result,
+            'view_filter_result': filtered_viewed_result,
+            'executeTime': (time.time() - st_viewed) * 1000
+        })
         if not filtered_viewed_result:
             return None
         else:
@@ -344,11 +359,11 @@ class FilterVideos(object):
         result = request_post(request_url=config_.VIDEO_FILTER_URL, request_data=request_data, timeout=1)
 
         if result is None:
-            log_.info('过滤失败，types: {}'.format(types))
+            # log_.info('过滤失败，types: {}'.format(types))
             return video_ids
 
         if result['code'] != 0:
-            log_.info('过滤失败，types: {}'.format(types))
+            # log_.info('过滤失败，types: {}'.format(types))
             return video_ids
 
         filtered_videos = result['data']