diff --git a/ad_tasks.py b/ad_tasks.py index 5ac8885..9e4071f 100644 --- a/ad_tasks.py +++ b/ad_tasks.py @@ -177,9 +177,11 @@ def send_cache_data(): print(f"area={area_all}") for area in area_all.split(','): key = f"ad::{gameid}_{locationid}::{channelid}::{area}::{locationid}" - if my_redis.sismember(key, id): - my_redis.srem(key, id) - my_redis.expire(f"ad::{id}::info", 1) + values = f"{id}_{locationid}" + pdb.set_trace() + if my_redis.sismember(key, values): + my_redis.srem(key, values) + my_redis.expire(f"adinfo::{values}::info", 1) log.info(f"remove {id} from {key} success!") except Exception: log.error("拆解过期数据出错!", exc_info=True)