增加写入title tag的任务

ad_arpu_update.py

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

ad_ecpm_update.py

@@ -2,7 +2,7 @@ import datetime
 import json
 import traceback
 
-from utils import request_get, send_msg_to_feishu
+from my_utils import request_get, send_msg_to_feishu
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

ad_no_ad_videos_update.py

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

ad_out_v1_get_offline_score_item.py

@@ -5,7 +5,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 config_, _ = set_config()
@@ -14,7 +14,7 @@ redis_helper = RedisHelper()
 
 from feature import get_item_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 def update_offline_score_item(dt):
     project = 'loghubods'

ad_out_v1_get_offline_score_item_new.py

@@ -4,7 +4,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 from records_process import records_process
@@ -15,7 +15,7 @@ redis_helper = RedisHelper()
 
 from feature import get_item_features as get_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 model_key = 'ad_out_v1'
 lr_model = LrModel('model/{}.json'.format(model_key))

ad_out_v1_get_offline_score_item_v2.py

@@ -4,7 +4,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 from records_process import records_process
@@ -15,7 +15,7 @@ redis_helper = RedisHelper()
 
 from feature import get_item_features as get_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 model_key = 'ad_out_v1'
 lr_model = LrModel('model/{}.json'.format(model_key))

ad_out_v1_get_offline_score_item_v2_debug.py

@@ -5,7 +5,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 config_, _ = set_config()
@@ -14,7 +14,7 @@ redis_helper = RedisHelper()
 
 from feature import get_item_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 def update_offline_score_item(dt):
     project = 'loghubods'

ad_out_v1_get_offline_score_user.py

@@ -5,7 +5,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 config_, _ = set_config()
@@ -14,7 +14,7 @@ redis_helper = RedisHelper()
 
 from feature import get_user_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 def update_offline_score_user(dt):
     project = 'loghubods'

ad_out_v1_get_offline_score_user_new.py

@@ -4,7 +4,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 from records_process import records_process
@@ -15,7 +15,7 @@ redis_helper = RedisHelper()
 
 from feature import get_user_features as get_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 model_key = 'ad_out_v1'
 lr_model = LrModel('model/{}.json'.format(model_key))

ad_out_v1_get_offline_score_user_v2.py

@@ -4,7 +4,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 from records_process import records_process
@@ -15,7 +15,7 @@ redis_helper = RedisHelper()
 
 from feature import get_user_features as get_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 model_key = 'ad_out_v1'
 lr_model = LrModel('model/{}.json'.format(model_key))

ad_out_v1_get_offline_score_user_v2_debug.py

@@ -5,7 +5,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 config_, _ = set_config()
@@ -14,7 +14,7 @@ redis_helper = RedisHelper()
 
 from feature import get_user_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 def update_offline_score_user(dt):
     project = 'loghubods'

ad_out_v1_get_offline_score_user_v3.py

@@ -4,7 +4,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 from records_process import records_process
@@ -15,7 +15,7 @@ redis_helper = RedisHelper()
 
 from feature import get_user_features as get_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 model_key = 'ad_out_v1'
 lr_model = LrModel('model/{}.json'.format(model_key))

ad_out_v1_get_offline_score_user_v3_debug.py

@@ -5,7 +5,7 @@ import datetime
 import traceback
 from threading import Timer
 from tqdm import tqdm
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
+from my_utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu
 from config import set_config
 from log import Log
 config_, _ = set_config()
@@ -14,7 +14,7 @@ redis_helper = RedisHelper()
 
 from feature import get_user_features
 from lr_model import LrModel
-from utils import exe_sql
+from my_utils import exe_sql
 
 def update_offline_score_user(dt):
     project = 'loghubods'

ad_out_v1_set_config.py

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

ad_threshold_auto_update.py

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

ad_user_data_update_with_new_strategy.py

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

ad_user_data_with_out_update.py

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

ad_user_video_predict.py

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

ad_users_data_update.py

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

ad_users_data_update_new.py

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

ad_video_data_update.py

@@ -2,7 +2,7 @@ import datetime
 import traceback
 import multiprocessing
 from threading import Timer
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu, send_msg_to_feishu_new
+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 log import Log
 config_, _ = set_config()

ad_video_data_update_with_new_strategy.py

@@ -2,7 +2,7 @@ import datetime
 import traceback
 import multiprocessing
 from threading import Timer
-from utils import RedisHelper, data_check, get_feature_data, send_msg_to_feishu, send_msg_to_feishu_new
+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 log import Log
 config_, _ = set_config()

alg_recsys_coldstart_offlinecheck.py

@@ -3,7 +3,7 @@ import time
 import traceback
 from config import set_config
 from log import Log
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper
 from datetime import datetime, timedelta
 

alg_recsys_rank_item_realtime_1day.py

@@ -3,14 +3,14 @@ import traceback
 import datetime
 from odps import ODPS
 from threading import Timer
-from utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
+from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
 from config import set_config
 from log import Log
 from alg_recsys_recall_4h_region_trend import records_process_for_list
 import json
 from datetime import datetime, timedelta
 import sys
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 
 
 config_, _ = set_config()

alg_recsys_rank_item_realtime_1h.py

@@ -3,14 +3,14 @@ import traceback
 import datetime
 from odps import ODPS
 from threading import Timer
-from utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
+from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
 from config import set_config
 from log import Log
 from alg_recsys_recall_4h_region_trend import records_process_for_list
 import json
 from datetime import datetime, timedelta
 import sys
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 
 
 config_, _ = set_config()

alg_recsys_rank_item_realtime_1hroot.py

@@ -3,14 +3,14 @@ import traceback
 import datetime
 from odps import ODPS
 from threading import Timer
-from utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
+from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
 from config import set_config
 from log import Log
 from alg_recsys_recall_4h_region_trend import records_process_for_list
 import json
 from datetime import datetime, timedelta
 import sys
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 
 
 config_, _ = set_config()

alg_recsys_rank_item_realtime_1hrootall.py

@@ -3,14 +3,14 @@ import traceback
 import datetime
 from odps import ODPS
 from threading import Timer
-from utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
+from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
 from config import set_config
 from log import Log
 from alg_recsys_recall_4h_region_trend import records_process_for_list
 import json
 from datetime import datetime, timedelta
 import sys
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 
 
 config_, _ = set_config()

alg_recsys_recall02_1h_region.py

@@ -8,7 +8,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer
-from utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
+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 log import Log

alg_recsys_recall_1h_noregion.py

@@ -7,7 +7,7 @@ from threading import Timer
 from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
-from utils import filter_video_status, check_table_partition_exits, filter_video_status_app, send_msg_to_feishu
+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 log import Log
 

alg_recsys_recall_1h_region.py

@@ -8,7 +8,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer
-from utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
+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 log import Log

alg_recsys_recall_24h_noregion.py

@@ -7,7 +7,7 @@ from threading import Timer
 from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
-from utils import filter_video_status, check_table_partition_exits, filter_video_status_app, \
+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 log import Log

alg_recsys_recall_24h_region.py

@@ -8,7 +8,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer, Thread
-from utils import RedisHelper, get_data_from_odps, filter_video_status, check_table_partition_exits, \
+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 log import Log

alg_recsys_recall_4h_region_trend.py

@@ -3,7 +3,7 @@ import traceback
 import datetime
 from odps import ODPS
 from threading import Timer
-from utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
+from my_utils import RedisHelper, get_data_from_odps, send_msg_to_feishu
 from config import set_config
 from log import Log
 from queue import Queue

alg_recsys_recall_aftermerge.py

@@ -9,7 +9,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer, Thread
-from utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
+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 log import Log

alg_recsys_recall_shield_videos.py

@@ -2,7 +2,7 @@
 import traceback
 from config import set_config
 from log import Log
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper
 import datetime
 import json

alg_recsys_recall_tags_videos.py

@@ -2,7 +2,7 @@
 import traceback
 from config import set_config
 from log import Log
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper
 from datetime import datetime, timedelta
 

alg_recsys_recall_tags_videos_v2.py

@@ -2,7 +2,7 @@
 import traceback
 from config import set_config
 from log import Log
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper
 from datetime import datetime, timedelta
 from odps import ODPS

alg_recsys_recall_undertake.py

@@ -2,7 +2,7 @@
 import traceback
 from config import set_config
 from log import Log
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper
 from datetime import datetime, timedelta
 

bottom_videos.py

@@ -5,7 +5,7 @@ import traceback
 import os
 import json
 
-from utils import execute_sql_from_odps, request_post, update_video_w_h_rate
+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 log import Log

bottom_videos_update.py

@@ -8,7 +8,7 @@ import traceback
 import datetime
 
 from pool_predict import get_videos_from_flow_pool
-from utils import filter_video_status
+from my_utils import filter_video_status
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

cal_24h_score.py

@@ -3,7 +3,7 @@ import sys
 import math
 import traceback
 import pandas as pd
-from utils import send_msg_to_feishu
+from my_utils import send_msg_to_feishu
 from config import set_config
 from log import Log
 config_, _ = set_config()

cal_hour_score.py

@@ -3,7 +3,7 @@ import sys
 import traceback
 import math
 import pandas as pd
-from utils import send_msg_to_feishu
+from my_utils import send_msg_to_feishu
 from config import set_config
 from log import Log
 config_, _ = set_config()

check_video_limit_distribute.py

@@ -3,7 +3,7 @@ import datetime
 import numpy as np
 from config import set_config
 from log import Log
-from utils import RedisHelper
+from my_utils import RedisHelper
 
 config_, _ = set_config()
 log_ = Log()

check_video_limit_distribute_new.py

@@ -3,7 +3,7 @@ import datetime
 import numpy as np
 from config import set_config
 from log import Log
-from utils import RedisHelper
+from my_utils import RedisHelper
 
 config_, _ = set_config()
 log_ = Log()

compose_score.py

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

data_monitor.py

@@ -5,7 +5,7 @@ import datetime
 
 from config import set_config
 from rov_train import process_data, process_predict_data
-from utils import send_msg_to_feishu
+from my_utils import send_msg_to_feishu
 
 config_, env = set_config()
 

export_24h_vid.py

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

export_hour_vid.py

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

flowpool_data_update.py

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

flowpool_data_update_with_level.py

@@ -7,7 +7,7 @@ import random
 import json
 
 from config import set_config
-from utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
+from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
     filter_political_videos
 from log import Log
 from db_helper import RedisHelper

flowpool_data_update_with_level_score.py

@@ -3,7 +3,7 @@ import traceback
 import json
 
 from config import set_config
-from utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
+from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
     filter_political_videos
 from log import Log
 from db_helper import RedisHelper

get_data.py

@@ -4,7 +4,7 @@ import process_feature
 
 from datetime import datetime as dt
 from config import set_config
-from utils import get_data_from_odps, write_to_pickle
+from my_utils import get_data_from_odps, write_to_pickle
 from log import Log
 
 config_, _ = set_config()

get_video_limit_list.py

@@ -2,7 +2,7 @@ import datetime
 import traceback
 from config import set_config
 from log import Log
-from utils import request_post, RedisHelper
+from my_utils import request_post, RedisHelper
 
 config_, _ = set_config()
 log_ = Log()

laohaokan_recommend_update.py

@@ -2,7 +2,7 @@ import datetime
 import traceback
 import gevent
 from db_helper import RedisHelper
-from utils import send_msg_to_feishu
+from my_utils import send_msg_to_feishu
 from config import set_config
 from log import Log
 

old_video_recall.py

@@ -5,7 +5,7 @@
 # @Software: PyCharm
 import pandas as pd
 from datetime import datetime
-from utils import get_data_from_odps, filter_video_status
+from my_utils import get_data_from_odps, filter_video_status
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

pool_predict.py

@@ -7,7 +7,7 @@ import traceback
 import random
 
 from config import set_config
-from utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
+from my_utils import request_post, filter_video_status, send_msg_to_feishu, filter_video_status_app, \
     filter_political_videos
 from log import Log
 from db_helper import RedisHelper

recommend_region_data_dup.py

@@ -11,7 +11,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer, Thread
-from utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
+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 log import Log

redis_data_monitor.py

@@ -1,6 +1,6 @@
 import datetime
 from config import set_config
-from utils import RedisHelper, send_msg_to_feishu
+from my_utils import RedisHelper, send_msg_to_feishu
 from log import Log
 
 config_, _ = set_config()

redis_test.py

@@ -1,4 +1,4 @@
-from utils import RedisHelper
+from my_utils import RedisHelper
 from config import set_config
 from log import Log
 import sys

region_rule_rank_day.py

@@ -9,7 +9,7 @@ import pandas as pd
 import math
 from odps import ODPS
 from threading import Timer
-from utils import RedisHelper, get_data_from_odps, filter_video_status
+from my_utils import RedisHelper, get_data_from_odps, filter_video_status
 from config import set_config
 from log import Log
 

region_rule_rank_h.py

@@ -17,7 +17,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer, Thread
-from utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
+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 log import Log

region_rule_rank_h_by24h.py

@@ -15,7 +15,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer, Thread
-from utils import RedisHelper, get_data_from_odps, filter_video_status, check_table_partition_exits, \
+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 log import Log

region_rule_rank_h_new.py

@@ -16,7 +16,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer, Thread
-from utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
+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 log import Log

region_rule_rank_h_v2.py

@@ -17,7 +17,7 @@ import math
 from functools import reduce
 from odps import ODPS
 from threading import Timer, Thread
-from utils import MysqlHelper, RedisHelper, get_data_from_odps, filter_video_status, filter_shield_video, \
+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 log import Log

relevant_top_videos.py

@@ -3,7 +3,7 @@ import json
 import time
 from config import set_config
 from db_helper import RedisHelper
-from utils import filter_video_status
+from my_utils import filter_video_status
 
 config_, _ = set_config()
 

religion_class_user_update.py

@@ -6,7 +6,7 @@ import pandas as pd
 from odps import ODPS
 from threading import Timer
 from get_data import get_data_from_odps
-from utils import send_msg_to_feishu
+from my_utils import send_msg_to_feishu
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

religion_class_videos_update.py

@@ -5,7 +5,7 @@ import pandas as pd
 from odps import ODPS
 from threading import Timer
 from get_data import get_data_from_odps
-from utils import send_msg_to_feishu
+from my_utils import send_msg_to_feishu
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

rov_data_check.py

@@ -7,7 +7,7 @@ from datetime import datetime as dt
 from threading import Timer
 from config import set_config
 from log import Log
-from utils import send_msg_to_feishu
+from my_utils import send_msg_to_feishu
 
 config_, env = set_config()
 log_ = Log()

rov_train.py

@@ -9,7 +9,7 @@ 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 utils import read_from_pickle, write_to_pickle, data_normalization, \
+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
 from db_helper import RedisHelper, MysqlHelper

rule_rank_day.py

@@ -2,7 +2,7 @@ import pandas as pd
 from odps import ODPS
 from datetime import datetime, timedelta
 from threading import Timer
-from utils import get_data_from_odps, filter_video_status
+from my_utils import get_data_from_odps, filter_video_status
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

rule_rank_day_by_30day.py

@@ -6,7 +6,7 @@ from threading import Timer
 from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
-from utils import filter_video_status, check_table_partition_exits
+from my_utils import filter_video_status, check_table_partition_exits
 from config import set_config
 from log import Log
 

rule_rank_h.py

@@ -4,7 +4,7 @@ import math
 from odps import ODPS
 from threading import Timer
 from get_data import get_data_from_odps
-from utils import filter_video_status
+from my_utils import filter_video_status
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

rule_rank_h_18_19.py

@@ -15,7 +15,7 @@ from get_data import get_data_from_odps
 from db_helper import RedisHelper, MysqlHelper
 from config import set_config
 from log import Log
-from utils import filter_video_status
+from my_utils import filter_video_status
 
 config_, env = set_config()
 log_ = Log()

rule_rank_h_by_24h.py

@@ -10,7 +10,7 @@ from threading import Timer
 from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
-from utils import filter_video_status, check_table_partition_exits, filter_video_status_app, \
+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 log import Log

rule_rank_h_by_48h.py

@@ -12,7 +12,7 @@ from threading import Timer
 from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
-from utils import filter_video_status, check_table_partition_exits
+from my_utils import filter_video_status, check_table_partition_exits
 from config import set_config
 from log import Log
 

rule_rank_h_new.py

@@ -7,7 +7,7 @@ from threading import Timer
 from datetime import datetime, timedelta
 from get_data import get_data_from_odps
 from db_helper import RedisHelper
-from utils import filter_video_status, check_table_partition_exits, filter_video_status_app, send_msg_to_feishu
+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 log import Log
 

shield_videos.py

@@ -3,7 +3,7 @@ import traceback
 import datetime
 from config import set_config
 from log import Log
-from utils import execute_sql_from_odps
+from my_utils import execute_sql_from_odps
 from db_helper import RedisHelper
 
 config_, _ = set_config()

special_mid_videos_update.py

@@ -9,7 +9,7 @@ from get_data import get_data_from_odps
 from db_helper import RedisHelper, MysqlHelper
 from config import set_config
 from log import Log
-from utils import request_post
+from my_utils import request_post
 
 config_, env = set_config()
 log_ = Log()

special_mids_update.py

@@ -9,7 +9,7 @@ from get_data import get_data_from_odps
 from db_helper import RedisHelper, MysqlHelper
 from config import set_config
 from log import Log
-from utils import filter_video_status_with_applet_rec
+from my_utils import filter_video_status_with_applet_rec
 
 config_, env = set_config()
 log_ = Log()

top_video_list.py

@@ -1,5 +1,5 @@
 import traceback
-from utils import request_post, filter_video_status, filter_video_status_app
+from my_utils import request_post, filter_video_status, filter_video_status_app
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

user_group_update.py

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

videos_filter.py

@@ -9,7 +9,7 @@ import pandas as pd
 from datetime import date, timedelta, datetime
 
 from region_rule_rank_h import region_code
-from utils import filter_video_status, send_msg_to_feishu, filter_video_status_app
+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 log import Log

videos_similarity.py

@@ -4,7 +4,7 @@ import datetime
 
 import pandas as pd
 from odps import ODPS
-from utils import filter_video_status
+from my_utils import filter_video_status
 from db_helper import RedisHelper
 from config import set_config
 from log import Log

whole_movies_update.py

@@ -9,7 +9,7 @@ from get_data import get_data_from_odps
 from db_helper import RedisHelper, MysqlHelper
 from config import set_config
 from log import Log
-from utils import filter_video_status_with_applet_rec
+from my_utils import filter_video_status_with_applet_rec
 
 config_, env = set_config()
 log_ = Log()

zhangbo/alg_recsys_recall_01_vid2titletags_redis.py

@@ -10,7 +10,7 @@ if root_dir not in sys.path:
 from odps import ODPS
 from threading import Timer
 import threading
-from utils import RedisHelper, execute_sql_from_odps
+from my_utils import RedisHelper, execute_sql_from_odps
 from config import set_config
 from log import Log
 import json