maxjhandsome
/
sysom
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

!37 新加ossre前后数据处理脚本 

Merge pull request !37 from chenshiyan0/master
This commit is contained in:
huangtuq 2022-02-24 08:01:23 +00:00 committed by Gitee
parent 1873cc5edb 48c09abc63
commit 370dc701c2
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
2 changed files with 211 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
sysom_api/service_scripts/ossre Executable file
View File

@ -0,0 +1,29 @@
#!/usr/bin/python3
# coding=utf-8
import json
import sys
###############################################################################
## {
## "service_name":"ossre",
## "实例IP":"192.168.1.101"
## }
## 解析参数方法：
## sysak ossre_client -d > /dev/null 2>&1 && cat /var/log/sysak/ossre.log
## sysak ossre_client -d > /dev/null 2>&1 实际ossre执行系统诊断命令，隐藏控制台输出
## cat /var/log/sysak/ossre.log 是ossre诊断结果，json格式
##
###############################################################################
args = json.loads(sys.argv[1])
result = {}
result['commands'] = []
cmd0 = {}
cmd0['instance'] = args["实例IP"]
cmd0['cmd'] = "sysak ossre_client -d > /dev/null 2>&1 " + " && " + "cat /var/log/sysak/ossre.log"
result['commands'].append(cmd0)
data = json.dumps(result)
print(data)

182
sysom_api/service_scripts/ossre_post Executable file
View File

@ -0,0 +1,182 @@
#!/usr/bin/python3
# coding=utf-8
import sys,os
import json
import traceback
if sys.version[0] == '2':
reload(sys)
sys.setdefaultencoding('utf8')
ERR_LEVEL = ["none","info","warning","error","critical","fatal"]
def ossre_to_sysom_json(raw):
retdata = {}
retdata["check_success"] = 0
retdata["CONFIG"] = {}
retdata["CONFIG"]["SCHED"] = {}
retdata["CONFIG"]["SCHED"]["summary"] = "未发现异常"
retdata["CONFIG"]["SCHED"]["level"] = "none"
retdata["CONFIG"]["MEM"] = {}
retdata["CONFIG"]["MEM"]["summary"] = "未发现异常"
retdata["CONFIG"]["MEM"]["level"] = "none"
retdata["CONFIG"]["IO"] = {}
retdata["CONFIG"]["IO"]["summary"] = "未发现异常"
retdata["CONFIG"]["IO"]["level"] = "none"
retdata["CONFIG"]["NET"] = {}
retdata["CONFIG"]["NET"]["summary"] = "未发现异常"
retdata["CONFIG"]["NET"]["level"] = "none"
retdata["CONFIG"]["HOTFIX"] = {}
retdata["CONFIG"]["HOTFIX"]["summary"] = "未发现异常"
retdata["CONFIG"]["HOTFIX"]["level"] = "none"
retdata["CONFIG"]["MISC"] = {}
retdata["CONFIG"]["MISC"]["summary"] = "未发现异常"
retdata["CONFIG"]["MISC"]["level"] = "none"
retdata["CONFIG"]["CPU"] = {}
retdata["CONFIG"]["CPU"]["summary"] = "未发现异常"
retdata["CONFIG"]["CPU"]["level"] = "none"
retdata["SLI"] = {}
retdata["SLI"]["CPU"] = {}
retdata["SLI"]["CPU"]["summary"] = "未发现异常"
retdata["SLI"]["CPU"]["level"] = "none"
retdata["SLI"]["MEM"] = {}
retdata["SLI"]["MEM"]["summary"] = "未发现异常"
retdata["SLI"]["MEM"]["level"] = "none"
retdata["SLI"]["IO"] = {}
retdata["SLI"]["IO"]["summary"] = "未发现异常"
retdata["SLI"]["IO"]["level"] = "none"
retdata["SLI"]["NET"] = {}
retdata["SLI"]["NET"]["summary"] = "未发现异常"
retdata["SLI"]["NET"]["level"] = "none"
retdata["SLI"]["HOTFIX"] = {}
retdata["SLI"]["HOTFIX"]["summary"] = "未发现异常"
retdata["SLI"]["HOTFIX"]["level"] = "none"
retdata["SLI"]["CRASH"] = {}
retdata["SLI"]["CRASH"]["summary"] = "未发现异常"
retdata["SLI"]["CRASH"]["level"] = "none"
retdata["SLI"]["MISC"] = {}
retdata["SLI"]["MISC"]["summary"] = "未发现异常"
retdata["SLI"]["MISC"]["level"] = "none"
retdata["ISSUE"] = {}
retdata["ISSUE"]["CRIT"] = {}
retdata["ISSUE"]["CRIT"]["summary"] = "未发现异常"
retdata["ISSUE"]["CRIT"]["level"] = "none"
retdata["ISSUE"]["ERR"] = {}
retdata["ISSUE"]["ERR"]["summary"] = "未发现异常"
retdata["ISSUE"]["ERR"]["level"] = "none"
retdata["ISSUE"]["WARN"] = {}
retdata["ISSUE"]["WARN"]["summary"] = "未发现异常"
retdata["ISSUE"]["WARN"]["level"] = "none"
retdata["LOG"] = {}
retdata["LOG"]["CRIT"] = {}
retdata["LOG"]["CRIT"]["summary"] = "未发现异常"
retdata["LOG"]["CRIT"]["level"] = "none"
retdata["LOG"]["ERR"] = {}
retdata["LOG"]["ERR"]["summary"] = "未发现异常"
retdata["LOG"]["ERR"]["level"] = "none"
retdata["LOG"]["WARN"] = {}
retdata["LOG"]["WARN"]["summary"] = "未发现异常"
retdata["LOG"]["WARN"]["level"] = "none"
retdata["HW"] = {}
retdata["HW"]["DMESG"] = {}
retdata["HW"]["DMESG"]["summary"] = "未发现异常"
retdata["HW"]["DMESG"]["level"] = "none"
try:
if "ossre" not in raw:
print (json.dumps(retdata, indent=4,ensure_ascii=False))
else:
rawdata_json = json.loads(raw)
retdata["check_success"] = 1
cust = rawdata_json["ossre"]["fields"]["cust"]
if "CONFIG" in cust:
for item in cust["CONFIG"]:
if retdata["CONFIG"][cust["CONFIG"][item]["category"]]["summary"] == "未发现异常":
retdata["CONFIG"][cust["CONFIG"][item]["category"]]["summary"] = ""
retdata["CONFIG"][cust["CONFIG"][item]["category"]]["summary"] += "%s\n"%cust["CONFIG"][item]["name"]
if len(cust["CONFIG"][item]["desc"]) != 0:
retdata["CONFIG"][cust["CONFIG"][item]["category"]]["summary"] += "%s\n"%cust["CONFIG"][item]["desc"]
retdata["CONFIG"][cust["CONFIG"][item]["category"]]["summary"] += "%s\n"%cust["CONFIG"][item]["summary"]
if ERR_LEVEL.index(cust["CONFIG"][item]["level"]) > ERR_LEVEL.index(retdata["CONFIG"][cust["CONFIG"][item]["category"]]["level"]):
retdata["CONFIG"][cust["CONFIG"][item]["category"]]["level"] = cust["CONFIG"][item]["level"]
if "SLI" in cust:
for item in cust["SLI"]:
if retdata["SLI"][cust["SLI"][item]["category"]]["summary"] == "未发现异常":
retdata["SLI"][cust["SLI"][item]["category"]]["summary"] = ""
retdata["SLI"][cust["SLI"][item]["category"]]["summary"] += "%s\n"%cust["SLI"][item]["name"]
if len(cust["SLI"][item]["desc"]) != 0:
retdata["SLI"][cust["SLI"][item]["category"]]["summary"] += "%s\n"%cust["SLI"][item]["desc"]
retdata["SLI"][cust["SLI"][item]["category"]]["summary"] += "%s\n"%cust["SLI"][item]["summary"]
if ERR_LEVEL.index(cust["SLI"][item]["level"]) > ERR_LEVEL.index(retdata["SLI"][cust["SLI"][item]["category"]]["level"]):
retdata["SLI"][cust["SLI"][item]["category"]]["level"] = cust["SLI"][item]["level"]
if "ISSUE" in cust:
for item in cust["ISSUE"]:
level = cust["ISSUE"][item]["level"]
if level in ERR_LEVEL:
if ERR_LEVEL.index(level) <= ERR_LEVEL.index("warning"):
level_idx = "WARN"
elif ERR_LEVEL.index(level) == ERR_LEVEL.index("error"):
level_idx = "ERR"
elif ERR_LEVEL.index(level) >= ERR_LEVEL.index("critical"):
level_idx = "CRIT"
else:
level_idx = "WARN"
if retdata["ISSUE"][level_idx]["summary"] == "未发现异常":
retdata["ISSUE"][level_idx]["summary"] = ""
retdata["ISSUE"][level_idx]["summary"] += "%s\n"%cust["ISSUE"][item]["summary"]
retdata["ISSUE"][level_idx]["summary"] += "%s\n\n"%cust["ISSUE"][item]["solution"]
retdata["ISSUE"][level_idx]["level"] = level
if "LOG" in cust:
for item in cust["LOG"]:
level = cust["LOG"][item]["level"]
if level in ERR_LEVEL:
if ERR_LEVEL.index(level) <= ERR_LEVEL.index("warning"):
level_idx = "WARN"
elif ERR_LEVEL.index(level) == ERR_LEVEL.index("error"):
level_idx = "ERR"
elif ERR_LEVEL.index(level) >= ERR_LEVEL.index("critical"):
level_idx = "CRIT"
else:
level_idx = "WARN"
if retdata["LOG"][level_idx]["summary"] == "未发现异常":
retdata["LOG"][level_idx]["summary"] = ""
retdata["LOG"][level_idx]["summary"] += "%s\n%s\n"%(cust["LOG"][item]["name"],cust["LOG"][item]["desc"])
retdata["LOG"][level_idx]["summary"] += "%s\n"%cust["LOG"][item]["summary"]
retdata["LOG"][level_idx]["level"] = level
if "HW" in cust:
for item in cust["HW"]:
level = cust["HW"][item]["level"]
if retdata["HW"]["DMESG"]["summary"] == "未发现异常":
retdata["HW"]["DMESG"]["summary"] = ""
if ERR_LEVEL.index(cust["HW"][item]["level"]) > ERR_LEVEL.index(retdata["HW"]["DMESG"]["level"]):
retdata["HW"]["DMESG"]["level"] = cust["HW"][item]["level"]
retdata["HW"]["DMESG"]["summary"] += "%s\n%s\n"%(cust["HW"][item]["name"],cust["HW"][item]["desc"])
retdata["HW"]["DMESG"]["summary"] += "%s\n"%cust["HW"][item]["summary"]
print (json.dumps(retdata, indent=4,ensure_ascii=False))
except:
print (json.dumps(retdata, indent=4,ensure_ascii=False))
#traceback.print_exc()
if __name__ == "__main__":
#iosdiagJoinData(sys.argv[1])
#cmd = "cat /var/log/sysak/ossre.log"
#cmd = "cat /tmp/ossre.log2"
#output = os.popen(cmd)
#rawdata = output.read()
#output.close()
#rawdata_json = json.loads(rawdata)
##print (json.dumps(rawdata_json,ensure_ascii=False,indent=4))
ossre_to_sysom_json(sys.argv[1])
#ossre_to_sysom_json(rawdata)