|
|
@@ -47,11 +47,19 @@ def update_to_redis(no_ad_videos_mapping_list):
|
|
|
for k, val in item.items():
|
|
|
redis_data[app_type][k] = val
|
|
|
# to redis
|
|
|
+ no_ad_app_type_list = []
|
|
|
redis_helper = RedisHelper()
|
|
|
for app_type, data in redis_data.items():
|
|
|
key_name = f"{config_.KEY_NAME_PREFIX_NO_AD_VIDEOS}{app_type}"
|
|
|
redis_helper.set_data_to_redis(key_name=key_name, value=json.dumps(data), expire_time=int(24*3600))
|
|
|
log_.info(f"to redis: app_type={app_type}, data={data}, key_name={key_name}")
|
|
|
+ no_ad_app_type_list.append(int(app_type))
|
|
|
+ # 此次无符合要求数据的app_type清空对应数据
|
|
|
+ for _, app_type in config_.APP_TYPE.items():
|
|
|
+ if app_type not in no_ad_app_type_list:
|
|
|
+ key_name = f"{config_.KEY_NAME_PREFIX_NO_AD_VIDEOS}{app_type}"
|
|
|
+ redis_helper.del_keys(key_name=key_name)
|
|
|
+ log_.info(f"del from redis: app_type={app_type}, key_name={key_name}")
|
|
|
|
|
|
|
|
|
def main():
|
