feat:修改定时脚本

zhangbo/07_ad_model_update_everyday.sh

@@ -7,8 +7,10 @@ bucketFeatureSavePath=/dw/recommend/model/12_ros_data_v3/
 model_name=ad_model_lr
 today="$(date +%Y%m%d)"
 today_early_1="$(date -d '1 days ago' +%Y%m%d)"
-beginStr=${today_early_1}08
-endStr=${today_early_1}23
+beginTime=08
+endTime=23
+beginStr=${today_early_1}${beginTime}
+endStr=${today_early_1}${endTime}
 
 
 # 1 判断依赖的数据表是否生产完成
@@ -16,7 +18,7 @@ source /root/anaconda3/bin/activate py37
 max_hour=15
 max_minute=00
 while true; do
-  python_return_code=$(python utils.py --excute_program check_ad_origin_hive --partition ${endStr})
+  python_return_code=$(python utils.py --excute_program check_ad_origin_hive --partition ${today_early_1} --hh ${endTime})
   if [ $python_return_code -eq 0 ]; then
     echo "Python程序返回0，退出循环。"
     break

zhangbo/utils.py

@@ -121,6 +121,7 @@ if __name__ == '__main__':
     parser = argparse.ArgumentParser(description='脚本utils')
     parser.add_argument('--excute_program', type=str, help='执行程序')
     parser.add_argument('--partition', type=str, help='表分区')
+    parser.add_argument('--hh', type=str, help='小时级分区时的小时')
     parser.add_argument('--project', type=str, help='表空间')
     parser.add_argument('--table', type=str, help='表名')
     args = parser.parse_args()