|
|
@@ -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():
|
caida