ops/promotion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

a

Browse Source
This commit is contained in:
root 2019-08-20 12:18:27 +08:00
parent 202abf4a44
commit 56b22ed002
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ad_tasks.py
View File

@ -96,14 +96,17 @@ def send_cache_data():
except: except:
item['y_offset'] = 0 item['y_offset'] = 0
try: try:
print(f"0={item}")
temp = {} temp = {}
temp['jump_param'] = item['jump_param'] temp['jump_param'] = item['jump_param']
pdb.set_trace()
if not isinstance(item.get('ad_property', {}), dict): if not isinstance(item.get('ad_property', {}), dict):
item['ad_property'] = dict(item.get('ad_property', {})) item['ad_property'] = json.loads(item.get('ad_property', {}))
item['ad_property'].update(temp) item['ad_property'].update(temp)
item['ad_property']=json.dumps(item['ad_property']) item['ad_property']=json.dumps(item['ad_property'])
except: print(f"1={item}")
pass except Except:
log.error(f"write {item}",exc_info=True)
all.append(item) all.append(item)
except Exception: except Exception:
@ -138,6 +141,7 @@ def send_cache_data():
remove_list = ('ad_num', 'gameid') remove_list = ('ad_num', 'gameid')
for item in remove_list: for item in remove_list:
line.pop(item) line.pop(item)
print(f"2={item}")
my_redis.hmset(f"ad::{line['id']}::info", line) my_redis.hmset(f"ad::{line['id']}::info", line)
my_redis.expire(f"ad::{line['id']}::info", 60) my_redis.expire(f"ad::{line['id']}::info", 60)
# my_redis.expire(f"ad::{line['id']}::info", 3600 * 24 * 7) # my_redis.expire(f"ad::{line['id']}::info", 3600 * 24 * 7)