diff --git a/task/summary_func.py b/task/summary_func.py index 47a6978..ae45e80 100644 --- a/task/summary_func.py +++ b/task/summary_func.py @@ -30,8 +30,8 @@ class SummaryFunc(Task): continue logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}') where = { - '_ut': 'Func', - '_event_time': { + '_event_name': 'Func', + '_ut': { '$gte': ts['cursor_st'], '$lt': ts['cursor_et'], } diff --git a/task/summary_join_hd.py b/task/summary_join_hd.py index f7094da..4871948 100644 --- a/task/summary_join_hd.py +++ b/task/summary_join_hd.py @@ -41,9 +41,9 @@ class SummaryJoinHd(Task): continue logger.info(f'开始处理{self.game_name} 处理 {source_coll} 游标 {ts}') where = { - '_ut': 'res', + '_event_name': 'res', 'function': 'hdgetprize', - '_event_time': { + '_ut': { '$gte': ts['cursor_st'], '$lt': ts['cursor_et'], }