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-18 15:13:06 +08:00
parent c05e827970
commit 36d4702d5f
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
task/summary_pay.py
View File

@ -62,7 +62,8 @@ class SummaryPay(Task):
bulk_data.append(UpdateOne({'orderid': model.orderid}, {'$set': data}, upsert=True)) bulk_data.append(UpdateOne({'orderid': model.orderid}, {'$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}字段异常 {msg}') ddsend_msg(f'严重警告！！！{self.game_name}.{source_coll}字段异常 {msg}')
bulk_data.append(UpdateOne({'orderid': item['orderid']}, {'$set': item}, upsert=True))
logger.error(repr(e)) logger.error(repr(e))
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)