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-30 11:47:41 +08:00
parent 7f9b1e3018
commit b2e5e2ceb3
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
task/summary_func.py
View File

@ -30,8 +30,8 @@ class SummaryFunc(Task):
continue continue
logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}') logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}')
where = { where = {
'_ut': 'Func', '_event_name': 'Func',
'_event_time': { '_ut': {
'$gte': ts['cursor_st'], '$gte': ts['cursor_st'],
'$lt': ts['cursor_et'], '$lt': ts['cursor_et'],
} }

4
task/summary_join_hd.py
View File

@ -41,9 +41,9 @@ class SummaryJoinHd(Task):
continue continue
logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}') logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}')
where = { where = {
'_ut': 'res', '_event_name': 'res',
'function': 'hdgetprize', 'function': 'hdgetprize',
'_event_time': { '_ut': {
'$gte': ts['cursor_st'], '$gte': ts['cursor_st'],
'$lt': ts['cursor_et'], '$lt': ts['cursor_et'],
} }