|
@@ -13,7 +13,6 @@ ODPS_CONFIG = {
|
|
|
|
|
|
|
|
def check_origin_hive(args):
|
|
def check_origin_hive(args):
|
|
|
project = "loghubods"
|
|
project = "loghubods"
|
|
|
- # table = "alg_recsys_view_sample_v2"
|
|
|
|
|
table = args.table
|
|
table = args.table
|
|
|
beginStr = args.beginStr
|
|
beginStr = args.beginStr
|
|
|
endStr = args.endStr
|
|
endStr = args.endStr
|
|
@@ -34,7 +33,7 @@ def check_origin_hive(args):
|
|
|
else:
|
|
else:
|
|
|
bot = FeishuBot()
|
|
bot = FeishuBot()
|
|
|
msg = (
|
|
msg = (
|
|
|
- f'推荐模型数据更新 \n【任务名称】:step1校验hive数据源\n【是否成功】:success\n【基础信息】:table:{table},beginStr:{beginStr},endStr:{endStr}\n【详细日志】:{exist_partition}')
|
|
|
|
|
|
|
+ f'推荐模型数据更新 \n【任务名称】:step1校验hive数据源\n【是否成功】:success\n【信息】:table:{table},beginStr:{beginStr},endStr:{endStr}\n【详细日志】:{exist_partition}')
|
|
|
bot.send_message(msg)
|
|
bot.send_message(msg)
|
|
|
print('0')
|
|
print('0')
|
|
|
|
|
|
Joe