feat:添加评估结果分析脚本

ad/01_ad_model_update.sh

@@ -169,15 +169,21 @@ model_upload_oss() {
 
 }
 
+model_predict() {
+  local python_return_code=$(python ${sh_path}/model_predict_analyse.py)
+}
+
 # 主方法
 main() {
-  init
+  # init
+
+  # check_ad_hive
 
-  check_ad_hive
+  # xgb_train
 
-  xgb_train
+  # model_upload_oss
 
-  model_upload_oss
+  model_predict
 }
 
 

ad/model_predict_analyse.py

@@ -0,0 +1,22 @@
+import argparse
+import sys
+
+from hdfs import InsecureClient
+
+client = InsecureClient("http://master-1-1.c-7f31a3eea195cb73.cn-hangzhou.emr.aliyuncs.com")
+
+if __name__ == '__main__':
+    # parser = argparse.ArgumentParser(description="model_predict_analyse.py")
+    # parser.add_argument("-p", "--predict_path_list", type=list, help="config file path")
+    # args = parser.parse_args()
+    #
+    # predict_path_list = args.predict_path_list
+    # # 判断参数是否正常
+    # if len(predict_path_list) != 2:
+    #     sys.exit(1)
+
+    with client.read("/dw/recommend/model/34_ad_predict_data/20241004_351_0927_1003_1000/*",
+                     encoding="utf-8") as reader:
+        content = reader.read()
+
+    print(content)