wuhao/data_cleaning
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

update

Browse Source
This commit is contained in:
kf_wuhao 2021-01-11 20:35:41 +08:00
parent a45b94687f
commit 9257424091
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
task/summary_func.py
View File

@ -48,7 +48,7 @@ class SummaryFunc(Task):
bulk_data.append(UpdateOne({'_id': data['_id']}, {'$set': data}, upsert=True)) bulk_data.append(UpdateOne({'_id': data['_id']}, {'$set': data}, upsert=True))
except Exception as e: except Exception as e:
msg = traceback.format_exc() msg = traceback.format_exc()
ddsend_msg(f'{self.game_name} {source_coll} 功能 {item["ftype"]} 字段异常 {msg}') ddsend_msg(f'{self.game_name} {source_coll} 功能打点 {item["ftype"]} 字段异常 {msg}')
logger.error(f'ftype {item["ftype"]} 字段异常 {msg}') logger.error(f'ftype {item["ftype"]} 字段异常 {msg}')
if bulk_data: if bulk_data:
self.local_db[self.dest_coll].bulk_write(bulk_data, ordered=False) self.local_db[self.dest_coll].bulk_write(bulk_data, ordered=False)