|
@@ -15,7 +15,7 @@ from feature import get_user_features
|
|
|
from lr_model import LrModel
|
|
from lr_model import LrModel
|
|
|
from utils import exe_sql
|
|
from utils import exe_sql
|
|
|
|
|
|
|
|
-def update_offline_score_item(dt):
|
|
|
|
|
|
|
+def update_offline_score_user(dt):
|
|
|
project = 'loghubods'
|
|
project = 'loghubods'
|
|
|
sql = """
|
|
sql = """
|
|
|
--odps sql
|
|
--odps sql
|
|
@@ -275,7 +275,7 @@ def timer_check(dt):
|
|
|
if data_count > 0:
|
|
if data_count > 0:
|
|
|
log_.info('update_offline_score_user start! {}'.format(data_count))
|
|
log_.info('update_offline_score_user start! {}'.format(data_count))
|
|
|
# 数据准备好，进行更新
|
|
# 数据准备好，进行更新
|
|
|
- update_offline_score_item(dt=yesterday_dt)
|
|
|
|
|
|
|
+ update_offline_score_user(dt=yesterday_dt)
|
|
|
log_.info('update_offline_score_user end!')
|
|
log_.info('update_offline_score_user end!')
|
|
|
else:
|
|
else:
|
|
|
# 数据没准备好，5分钟后重新检查
|
|
# 数据没准备好，5分钟后重新检查
|
