@@ -34,7 +34,7 @@ def check_origin_hive(args):
else:
bot = FeishuBot()
msg = (
- f'推荐模型数据更新 \n --step1【校验hive数据源】【success】:\n beginStr:{beginStr},endStr:{endStr}\n,detail:{exist_partition}')
+ f'推荐模型数据更新 \n --step1【校验hive数据源】【success】:\ntable:{table},beginStr:{beginStr},endStr:{endStr}\n,detail:{exist_partition}')
bot.send_message(msg)
print('0')
@@ -3,10 +3,11 @@ set -ex
#partitionDt="$(date -d '1 days ago' +%Y%m%d)"
#partitionHh="14"
-table='alg_recsys_sample_all_test'
+#table='alg_recsys_sample_all_test'
+table='alg_recsys_sample_all'
-beginStr=2024061600
-endStr=2024061623
+beginStr=2024070400
+endStr=2024070423
# 0 判断上游表是否生产完成,最长等待到12点
source /root/anaconda3/bin/activate py37