From b2e5e2ceb396699dc5d2e01686c97ebdccba163b Mon Sep 17 00:00:00 2001 From: kf_wuhao <15392746632@qq.com> Date: Sat, 30 Jan 2021 11:47:41 +0800 Subject: [PATCH] update --- task/summary_func.py | 4 ++-- task/summary_join_hd.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) 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'], }