增加写入title tag的任务

ad_arpu_update.py

@@ -4,7 +4,7 @@ import time
 import traceback
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_ecpm_update.py

@@ -4,7 +4,7 @@ import traceback
 
 from my_utils import request_get, send_msg_to_feishu
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

ad_no_ad_videos_update.py

@@ -2,7 +2,7 @@ import datetime
 import json
 import traceback
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu_new
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_out_v1_get_offline_score_item.py

@@ -6,7 +6,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_out_v1_get_offline_score_item_new.py

@@ -5,7 +5,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from records_process import records_process
 

ad_out_v1_get_offline_score_item_v2.py

@@ -5,7 +5,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from records_process import records_process
 

ad_out_v1_get_offline_score_item_v2_debug.py

@@ -6,7 +6,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_out_v1_get_offline_score_user.py

@@ -6,7 +6,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_out_v1_get_offline_score_user_new.py

@@ -5,7 +5,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from records_process import records_process
 

ad_out_v1_get_offline_score_user_v2.py

@@ -5,7 +5,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from records_process import records_process
 

ad_out_v1_get_offline_score_user_v2_debug.py

@@ -6,7 +6,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_out_v1_get_offline_score_user_v3.py

@@ -5,7 +5,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from records_process import records_process
 

ad_out_v1_get_offline_score_user_v3_debug.py

@@ -6,7 +6,7 @@ import traceback
 from threading import Timer
 from tqdm import tqdm
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_out_v1_set_config.py

@@ -3,7 +3,7 @@ import datetime
 import traceback
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_roi_param_update.py

@@ -1,6 +1,6 @@
 import datetime
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

ad_threshold_auto_update.py

@@ -8,7 +8,7 @@ from threading import Timer
 import pandas as pd
 
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu, request_get
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_user_data_update_with_new_strategy.py

@@ -2,7 +2,7 @@ import datetime
 import traceback
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_user_data_with_out_update.py

@@ -2,7 +2,7 @@ import datetime
 import traceback
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_user_video_predict.py

@@ -5,7 +5,7 @@ import numpy as np
 import pandas as pd
 from odps import ODPS
 from my_utils import data_check, get_feature_data, send_msg_to_feishu_new, RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_users_data_update.py

@@ -2,7 +2,7 @@ import datetime
 import traceback
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_users_data_update_new.py

@@ -2,7 +2,7 @@ import datetime
 import traceback
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_video_data_update.py

@@ -3,7 +3,7 @@ import traceback
 import multiprocessing
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu, send_msg_to_feishu_new
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

ad_video_data_update_with_new_strategy.py

@@ -3,7 +3,7 @@ import traceback
 import multiprocessing
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu, send_msg_to_feishu_new
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

alg_recsys_coldstart_offlinecheck.py

@@ -1,7 +1,7 @@
 # -*- coding: utf-8 -*-
 import time
 import traceback
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper

alg_recsys_rank_item_realtime_1day.py

@@ -4,7 +4,7 @@ import datetime
 from odps import ODPS
 from threading import Timer
 from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from alg_recsys_recall_4h_region_trend import records_process_for_list
 import json

alg_recsys_rank_item_realtime_1h.py

@@ -4,7 +4,7 @@ import datetime
 from odps import ODPS
 from threading import Timer
 from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from alg_recsys_recall_4h_region_trend import records_process_for_list
 import json

alg_recsys_rank_item_realtime_1hroot.py

@@ -4,7 +4,7 @@ import datetime
 from odps import ODPS
 from threading import Timer
 from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from alg_recsys_recall_4h_region_trend import records_process_for_list
 import json

alg_recsys_rank_item_realtime_1hrootall.py

@@ -4,7 +4,7 @@ import datetime
 from odps import ODPS
 from threading import Timer
 from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from alg_recsys_recall_4h_region_trend import records_process_for_list
 import json

alg_recsys_recall02_1h_region.py

@@ -10,7 +10,7 @@ from odps import ODPS
 from threading import Timer
 from my_utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
     check_table_partition_exits, filter_video_status_app, send_msg_to_feishu, filter_political_videos
-from config import set_config
+from my_config import set_config
 from log import Log
 from check_video_limit_distribute import update_limit_video_score
 

alg_recsys_recall_1h_noregion.py

@@ -8,7 +8,7 @@ from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
 from my_utils import filter_video_status, check_table_partition_exits, filter_video_status_app, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

alg_recsys_recall_1h_region.py

@@ -10,7 +10,7 @@ from odps import ODPS
 from threading import Timer
 from my_utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
     check_table_partition_exits, filter_video_status_app, send_msg_to_feishu, filter_political_videos
-from config import set_config
+from my_config import set_config
 from log import Log
 from check_video_limit_distribute import update_limit_video_score
 

alg_recsys_recall_24h_noregion.py

@@ -9,7 +9,7 @@ from get_data import get_data_from_odps
 from db_helper import RedisHelper
 from my_utils import filter_video_status, check_table_partition_exits, filter_video_status_app, \
     request_post, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

alg_recsys_recall_24h_region.py

@@ -10,7 +10,7 @@ from odps import ODPS
 from threading import Timer, Thread
 from my_utils import RedisHelper, get_data_from_odps, filter_video_status, check_table_partition_exits, \
     filter_video_status_app, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 
 # os.environ['NUMEXPR_MAX_THREADS'] = '16'

alg_recsys_recall_4h_region_trend.py

@@ -4,7 +4,7 @@ import datetime
 from odps import ODPS
 from threading import Timer
 from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 from queue import Queue
 from tqdm import tqdm

alg_recsys_recall_aftermerge.py

@@ -11,7 +11,7 @@ from odps import ODPS
 from threading import Timer, Thread
 from my_utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
     check_table_partition_exits, filter_video_status_app, send_msg_to_feishu, filter_political_videos
-from config import set_config
+from my_config import set_config
 from log import Log
 from check_video_limit_distribute import update_limit_video_score
 

alg_recsys_recall_shield_videos.py

@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 import traceback
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper

alg_recsys_recall_tags_videos.py

@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 import traceback
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper

alg_recsys_recall_tags_videos_v2.py

@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 import traceback
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper

alg_recsys_recall_undertake.py

@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 import traceback
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper

app_rank_h.py

@@ -8,7 +8,7 @@ from datetime import datetime as dt
 from threading import Timer
 from log import Log
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from odps import ODPS
 
 log_ = Log()

bottom_videos.py

@@ -7,7 +7,7 @@ import json
 
 from my_utils import execute_sql_from_odps, request_post, update_video_w_h_rate
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, env = set_config()

bottom_videos_update.py

@@ -10,7 +10,7 @@ import datetime
 from pool_predict import get_videos_from_flow_pool
 from my_utils import filter_video_status
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

cal_24h_score.py

@@ -4,7 +4,7 @@ import math
 import traceback
 import pandas as pd
 from my_utils import send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

cal_hour_score.py

@@ -4,7 +4,7 @@ import traceback
 import math
 import pandas as pd
 from my_utils import send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

check_video_limit_distribute.py

@@ -1,7 +1,7 @@
 import gevent
 import datetime
 import numpy as np
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import RedisHelper
 

check_video_limit_distribute_new.py

@@ -1,7 +1,7 @@
 import gevent
 import datetime
 import numpy as np
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import RedisHelper
 

compose_score.py

@@ -3,7 +3,7 @@ import traceback
 import pandas as pd
 from db_helper import RedisHelper
 from my_utils import send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

data_expire_time_update.py

@@ -1,6 +1,6 @@
 import datetime
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

data_monitor.py

@@ -3,7 +3,7 @@ import numpy as np
 import pandas as pd
 import datetime
 
-from config import set_config
+from my_config import set_config
 from rov_train import process_data, process_predict_data
 from my_utils import send_msg_to_feishu
 

db_helper.py

@@ -2,7 +2,7 @@
 import redis
 import psycopg2
 import pymysql
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

export_24h_vid.py

@@ -2,7 +2,7 @@ import sys
 import traceback
 import pandas as pd
 from my_utils import get_data_from_odps, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

export_hour_vid.py

@@ -2,7 +2,7 @@ import sys
 import traceback
 import pandas as pd
 from my_utils import get_data_from_odps, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

flowpool_abtest_config_update.py

@@ -4,7 +4,7 @@
 # @Time: 2023/9/23 13:31
 # @Software: PyCharm
 import json
-from config import set_config
+from my_config import set_config
 from log import Log
 from db_helper import RedisHelper
 

flowpool_data_update.py

@@ -5,7 +5,7 @@ import os
 import traceback
 import random
 
-from config import set_config
+from my_config import set_config
 from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
     filter_political_videos
 from log import Log

flowpool_data_update_with_level.py

@@ -6,7 +6,7 @@ import traceback
 import random
 import json
 
-from config import set_config
+from my_config import set_config
 from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
     filter_political_videos
 from log import Log

flowpool_data_update_with_level_score.py

@@ -2,7 +2,7 @@ import time
 import traceback
 import json
 
-from config import set_config
+from my_config import set_config
 from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
     filter_political_videos
 from log import Log

flowpool_level_weight_update.py

@@ -1,6 +1,6 @@
 import json
 
-from config import set_config
+from my_config import set_config
 from log import Log
 from db_helper import RedisHelper
 

get_data.py

@@ -3,7 +3,7 @@ import datetime
 import process_feature
 
 from datetime import datetime as dt
-from config import set_config
+from my_config import set_config
 from my_utils import get_data_from_odps, write_to_pickle
 from log import Log
 

get_video_limit_list.py

@@ -1,6 +1,6 @@
 import datetime
 import traceback
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import request_post, RedisHelper
 

laohaokan_recommend_update.py

@@ -3,7 +3,7 @@ import traceback
 import gevent
 from db_helper import RedisHelper
 from my_utils import send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, env = set_config()

log_conf.py

@@ -3,7 +3,7 @@ import logging
 import aliyun
 import os
 import time
-from config import set_config
+from my_config import set_config
 config_, _ = set_config()
 
 # 本地日志存储路径

my_utils.py

@@ -7,7 +7,7 @@ import traceback
 import pandas as pd
 
 from odps import ODPS
-from config import set_config
+from my_config import set_config
 from db_helper import HologresHelper, MysqlHelper, RedisHelper
 from log import Log
 from collections import defaultdict

old_video_recall.py

@@ -7,7 +7,7 @@ import pandas as pd
 from datetime import datetime
 from my_utils import get_data_from_odps, filter_video_status
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, env = set_config()

pool_predict.py

@@ -6,7 +6,7 @@ import os
 import traceback
 import random
 
-from config import set_config
+from my_config import set_config
 from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
     filter_political_videos
 from log import Log

recommend_region_data_dup.py

@@ -13,7 +13,7 @@ from odps import ODPS
 from threading import Timer, Thread
 from my_utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
     check_table_partition_exits, filter_video_status_app, send_msg_to_feishu, filter_political_videos
-from config import set_config
+from my_config import set_config
 from log import Log
 from check_video_limit_distribute import update_limit_video_score
 

recommend_region_data_status_update.py

@@ -1,5 +1,5 @@
 import datetime
-from config import set_config
+from my_config import set_config
 from log import Log
 from db_helper import RedisHelper
 

redis_data_monitor.py

@@ -1,5 +1,5 @@
 import datetime
-from config import set_config
+from my_config import set_config
 from my_utils import RedisHelper, send_msg_to_feishu
 from log import Log
 

redis_test.py

@@ -1,5 +1,5 @@
 from my_utils import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 import sys
 sys.path.append("zhangbo/")

region_rule_rank_day.py

@@ -10,7 +10,7 @@ import math
 from odps import ODPS
 from threading import Timer
 from my_utils import RedisHelper, get_data_from_odps, filter_video_status
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

region_rule_rank_h.py

@@ -19,7 +19,7 @@ from odps import ODPS
 from threading import Timer, Thread
 from my_utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
     check_table_partition_exits, filter_video_status_app, send_msg_to_feishu, filter_political_videos
-from config import set_config
+from my_config import set_config
 from log import Log
 from check_video_limit_distribute import update_limit_video_score
 

region_rule_rank_h_by24h.py

@@ -17,7 +17,7 @@ from odps import ODPS
 from threading import Timer, Thread
 from my_utils import RedisHelper, get_data_from_odps, filter_video_status, check_table_partition_exits, \
     filter_video_status_app, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 
 # os.environ['NUMEXPR_MAX_THREADS'] = '16'

region_rule_rank_h_new.py

@@ -18,7 +18,7 @@ from odps import ODPS
 from threading import Timer, Thread
 from my_utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
     check_table_partition_exits, filter_video_status_app, send_msg_to_feishu, filter_political_videos
-from config import set_config
+from my_config import set_config
 from log import Log
 from check_video_limit_distribute_new import update_limit_video_score
 

region_rule_rank_h_v2.py

@@ -19,7 +19,7 @@ from odps import ODPS
 from threading import Timer, Thread
 from my_utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
     check_table_partition_exits, filter_video_status_app, send_msg_to_feishu, filter_political_videos
-from config import set_config
+from my_config import set_config
 from log import Log
 from check_video_limit_distribute import update_limit_video_score
 

relevant_top_videos.py

@@ -1,7 +1,7 @@
 import pandas as pd
 import json
 import time
-from config import set_config
+from my_config import set_config
 from db_helper import RedisHelper
 from my_utils import filter_video_status
 

religion_class_user_update.py

@@ -8,7 +8,7 @@ from threading import Timer
 from get_data import get_data_from_odps
 from my_utils import send_msg_to_feishu
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, env = set_config()

religion_class_videos_update.py

@@ -7,7 +7,7 @@ from threading import Timer
 from get_data import get_data_from_odps
 from my_utils import send_msg_to_feishu
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, env = set_config()

religion_videos_update.py

@@ -4,7 +4,7 @@ from odps import ODPS
 from threading import Timer
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, env = set_config()

rov_data_check.py

@@ -5,7 +5,7 @@ import traceback
 from odps import ODPS
 from datetime import datetime as dt
 from threading import Timer
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import send_msg_to_feishu
 

rov_train.py

@@ -8,7 +8,7 @@ import pandas as pd
 from sklearn.model_selection import train_test_split
 from sklearn.metrics import mean_absolute_error, r2_score, mean_absolute_percentage_error
 
-from config import set_config
+from my_config import set_config
 from my_utils import read_from_pickle, write_to_pickle, data_normalization, \
     request_post, filter_video_status, update_video_w_h_rate, filter_video_status_app, filter_shield_video
 from log import Log

rule_rank_day.py

@@ -4,7 +4,7 @@ from datetime import datetime, timedelta
 from threading import Timer
 from my_utils import get_data_from_odps, filter_video_status
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

rule_rank_day_by_30day.py

@@ -7,7 +7,7 @@ from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
 from my_utils import filter_video_status, check_table_partition_exits
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

rule_rank_h.py

@@ -6,7 +6,7 @@ from threading import Timer
 from get_data import get_data_from_odps
 from my_utils import filter_video_status
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

rule_rank_h_18_19.py

@@ -13,7 +13,7 @@ from odps import ODPS
 from threading import Timer
 from get_data import get_data_from_odps
 from db_helper import RedisHelper, MysqlHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import filter_video_status
 

rule_rank_h_by_24h.py

@@ -12,7 +12,7 @@ from get_data import get_data_from_odps
 from db_helper import RedisHelper
 from my_utils import filter_video_status, check_table_partition_exits, filter_video_status_app, \
     request_post, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

rule_rank_h_by_48h.py

@@ -13,7 +13,7 @@ from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
 from my_utils import filter_video_status, check_table_partition_exits
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

rule_rank_h_new.py

@@ -8,7 +8,7 @@ from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
 from my_utils import filter_video_status, check_table_partition_exits, filter_video_status_app, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

shield_videos.py

@@ -1,7 +1,7 @@
 import datetime
 import traceback
 import datetime
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper

special_mid_videos_update.py

@@ -7,7 +7,7 @@ from odps import ODPS
 from threading import Timer
 from get_data import get_data_from_odps
 from db_helper import RedisHelper, MysqlHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import request_post
 

special_mids_update.py

@@ -7,7 +7,7 @@ from odps import ODPS
 from threading import Timer
 from get_data import get_data_from_odps
 from db_helper import RedisHelper, MysqlHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import filter_video_status_with_applet_rec
 

top_video_list.py

@@ -1,7 +1,7 @@
 import traceback
 from my_utils import request_post, filter_video_status, filter_video_status_app
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

update_in_flowpool_count_switch.py

@@ -1,4 +1,4 @@
-from config import set_config
+from my_config import set_config
 from log import Log
 from db_helper import RedisHelper
 

user_group_update.py

@@ -6,7 +6,7 @@ import traceback
 import gevent
 from threading import Timer
 from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
-from config import set_config
+from my_config import set_config
 from log import Log
 config_, _ = set_config()
 log_ = Log()

videos_filter.py

@@ -11,7 +11,7 @@ from datetime import date, timedelta, datetime
 from region_rule_rank_h import region_code
 from my_utils import filter_video_status, send_msg_to_feishu, filter_video_status_app
 from db_helper import RedisHelper, MysqlHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, env = set_config()

videos_similarity.py

@@ -6,7 +6,7 @@ import pandas as pd
 from odps import ODPS
 from my_utils import filter_video_status
 from db_helper import RedisHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 
 config_, _ = set_config()

whole_movies_update.py

@@ -7,7 +7,7 @@ from odps import ODPS
 from threading import Timer
 from get_data import get_data_from_odps
 from db_helper import RedisHelper, MysqlHelper
-from config import set_config
+from my_config import set_config
 from log import Log
 from my_utils import filter_video_status_with_applet_rec
 

zhangbo/alg_recsys_recall_01_vid2titletags_redis.py

@@ -11,7 +11,7 @@ from odps import ODPS
 from threading import Timer
 import threading
 from my_utils import RedisHelper, execute_sql_from_odps
-from config import set_config
+from my_config import set_config
 from log import Log
 import json
 from datetime import datetime