|
|
@@ -2,14 +2,16 @@
|
|
|
set -ex
|
|
|
|
|
|
partitionDt="$(date -d '1 days ago' +%Y%m%d)"
|
|
|
+partitionHh="14"
|
|
|
table='alg_recsys_sample_all_new'
|
|
|
|
|
|
# 0 判断上游表是否生产完成，最长等待到12点
|
|
|
source /root/anaconda3/bin/activate py37
|
|
|
max_hour=11
|
|
|
max_minute=00
|
|
|
+echo "开始校验是否生产完数据，分区信息：dt:${partitionDt},hh:${partitionHh}"
|
|
|
while true; do
|
|
|
- python_return_code=$(python checkHiveDataUtil.py --table ${table} --partitionDt ${partitionDt} --partitionHh 14)
|
|
|
+ python_return_code=$(python checkHiveDataUtil.py --table ${table} --partitionDt ${partitionDt} --partitionHh ${partitionHh})
|
|
|
if [ $python_return_code -eq 0 ]; then
|
|
|
echo "Python程序返回0，校验存在数据，退出循环。"
|
|
|
break
|
Joe