|
@@ -168,8 +168,8 @@ def cal_score(df, param):
|
|
|
|
|
|
def add_videos(initial_df, now_date, rule_key, region, data_key):
|
|
|
"""
|
|
|
- 20点地域小时级数据列表中增加7点-19点优质视频
|
|
|
- :param initial_df: 20点地域小时级筛选结果
|
|
|
+ 地域小时级数据列表中增加前6h优质视频
|
|
|
+ :param initial_df: 地域小时级筛选结果
|
|
|
:param now_date:
|
|
|
:param data_key:
|
|
|
:param region:
|
|
@@ -178,7 +178,10 @@ def add_videos(initial_df, now_date, rule_key, region, data_key):
|
|
|
"""
|
|
|
redis_helper = RedisHelper()
|
|
|
pre_h_data = []
|
|
|
- for pre_h in range(7, 20):
|
|
|
+ for pre_h in range(1, 7):
|
|
|
+ pre_date = now_date - datetime.timedelta(hours=pre_h)
|
|
|
+
|
|
|
+
|
|
|
pre_h_recall_key_name = f"{config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H}{region}:{data_key}:{rule_key}:" \
|
|
|
f"{datetime.datetime.strftime(now_date, '%Y%m%d')}:{pre_h}"
|
|
|
initial_data = redis_helper.get_all_data_from_zset(key_name=pre_h_recall_key_name, with_scores=True)
|