00_test.sh 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. #!/bin/sh
  2. set -x
  3. source /root/anaconda3/bin/activate py37
  4. # 模型保存路径
  5. model_save_path=/dw/recommend/model/35_ad_model/model_xgb_351_1000_v2_1009_1015
  6. MODEL_OSS_PATH=oss://art-recommend.oss-cn-hangzhou.aliyuncs.com/zhangbo/
  7. model_name=model_xgb_351_1000_v2
  8. predict_analyse_file_path=/root/zhaohp/XGB/predict_analyse_file/20241014_351_1000_analyse.txt
  9. start_time=$(date +%s)
  10. # 保存模型评估的分析结果
  11. old_incr_rate_avg=0
  12. new_incr_rate_avg=0
  13. declare -A old_score_map
  14. declare -A new_score_map
  15. count=0
  16. max_line=10
  17. old_total_diff=0
  18. new_total_diff=0
  19. while read -r line && [ ${count} -lt ${max_line} ]; do
  20. # 使用 ! 取反判断,只有当行中不包含 "cid" 时才执行继续的逻辑
  21. if [[ "${line}" == *"cid"* ]]; then
  22. continue
  23. fi
  24. read -a numbers <<< "${line}"
  25. # 分数分别保存
  26. old_score_map[${numbers[0]}]=${numbers[6]}
  27. new_score_map[${numbers[0]}]=${numbers[7]}
  28. old_total_diff=$( echo "${old_total_diff} + ${numbers[6]}" | bc -l )
  29. new_total_diff=$( echo "${new_total_diff} + ${numbers[7]}" | bc -l )
  30. count=$((${count} + 1))
  31. done < "${predict_analyse_file_path}"
  32. old_incr_rate_avg=$( echo "scale=6; ${old_total_diff} / ${count}" | bc -l )
  33. new_incr_rate_avg=$( echo "scale=6; ${new_total_diff} / ${count}" | bc -l )
  34. echo "老模型Top10差异平均值: ${old_incr_rate_avg}"
  35. echo "新模型Top10差异平均值: ${new_incr_rate_avg}"
  36. echo "新老模型分数对比: "
  37. for cid in "${!new_score_map[@]}"; do
  38. echo "\t CID: $cid, 老模型分数: ${old_score_map[$cid]}, 新模型分数: ${new_score_map[$cid]}"
  39. done
  40. msg=" 广告模型文件更新完成"
  41. msg+="\n\t - 老模型Top10差异平均值: ${old_incr_rate_avg}"
  42. msg+="\n\t - 新模型Top10差异平均值: ${new_incr_rate_avg}"
  43. msg+="\n\t - 模型在HDFS中的路径: ${model_save_path}"
  44. msg+="\n\t - 模型上传路径: ${MODEL_OSS_PATH}/${model_name}.tar.gz"
  45. top10_msg = "| CID | 老模型 | 新模型 | \n| ---- | -------- | -------- | "
  46. for cid in "${!new_score_map[@]}"; do
  47. top10_msg="${top10_msg} \n| ${cid} | ${old_score_map[$cid]} | ${new_score_map[$cid]} | "
  48. done
  49. /root/anaconda3/bin/python ${sh_path}/ad_monitor_util.py --level info --msg "${msg}" --start "${start_time}" --elapsed "10000" --top10 "${top10_msg}"