top10_abnormal_videos = {}

ad_video_data_update.py

@@ -304,9 +304,11 @@ def main():
         dt = datetime.datetime.strftime(now_date, '%Y%m%d')
         log_.info(f"now_date: {dt}")
         # 获取昨天top10中的异常视频（裂变视频）
-        top10_abnormal_videos = get_top10_abnormal_videos_return(
-            dt=dt, filter_param=config_.ad_model_data['top10_videos'].get('abnormal_filter_param')
-        )
+        # top10_abnormal_videos = get_top10_abnormal_videos_return(
+        #     dt=dt, filter_param=config_.ad_model_data['top10_videos'].get('abnormal_filter_param')
+        # )
+        # 暂停1.5倍回流视频减少广告策略
+        top10_abnormal_videos = {}
         update_params = config_.AD_VIDEO_DATA_PARAMS
         pool = multiprocessing.Pool(processes=len(update_params))
         for video_key, video_params in update_params.items():