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

add tags field

Browse Source
This commit is contained in:
pengtao 2019-11-06 14:19:41 +08:00
parent 43e2aadfd2
commit 4fc5007b66
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
taptap/taptap_report.py
View File

@ -22,6 +22,11 @@ class TapTapReport:
self.day = day self.day = day
self.bday = (datetime.datetime.strptime(self.day, "%Y-%m-%d") - datetime.timedelta(days=1)).strftime('%Y-%m-%d') self.bday = (datetime.datetime.strptime(self.day, "%Y-%m-%d") - datetime.timedelta(days=1)).strftime('%Y-%m-%d')
def clear_noice(self):
# 结合前后2天的数据，清理diff_order >200的数据
pass
def build_report(self): def build_report(self):
mydb = MysqlBase(**self.db_conf) mydb = MysqlBase(**self.db_conf)
@ -33,7 +38,7 @@ class TapTapReport:
b_d = self.split_order_data(item) b_d = self.split_order_data(item)
for key in b_d: for key in b_d:
gameid_order.setdefault(key, {}).update(b_d[key]) gameid_order.setdefault(key, {}).update(b_d[key])
pdb.set_trace()
for key in gameid_order.keys(): for key in gameid_order.keys():
all.setdefault(key, {})['gameid'] = key.split("#")[0] all.setdefault(key, {})['gameid'] = key.split("#")[0]
all[key]['catename'] = key.split('#')[1] all[key]['catename'] = key.split('#')[1]
@ -72,7 +77,8 @@ class TapTapReport:
for line in all.values(): for line in all.values():
try: try:
mydb.insert("taptap_data", line) print(line)
# mydb.insert("taptap_data", line)
except Exception: except Exception:
log.error(f"install 2 db failed ,values={line}", exc_info=True) log.error(f"install 2 db failed ,values={line}", exc_info=True)