|
|
@@ -289,13 +289,13 @@ def dup_to_redis(h_video_ids, now_date, now_h, rule_key, region_24h_rule_key, re
|
|
|
if redis_helper.key_exists(key_name=day_key_name):
|
|
|
day_data = redis_helper.get_data_zset_with_index(
|
|
|
key_name=day_key_name, start=0, end=-1, with_scores=True)
|
|
|
- log_.info(f'day data count = {len(day_data)}')
|
|
|
+ log_.info(f'24h data count = {len(day_data)}')
|
|
|
day_dup = {}
|
|
|
for video_id, score in day_data:
|
|
|
if int(video_id) not in h_video_ids:
|
|
|
day_dup[int(video_id)] = score
|
|
|
h_video_ids.append(int(video_id))
|
|
|
- log_.info(f"day data dup count = {len(day_dup)}")
|
|
|
+ log_.info(f"24h data dup count = {len(day_dup)}")
|
|
|
day_dup_key_name = \
|
|
|
f"{config_.RECALL_KEY_NAME_PREFIX_DUP2_REGION_24H_H}{region}.{rule_key}." \
|
|
|
f"{datetime.datetime.strftime(now_date, '%Y%m%d')}.{now_h}"
|
