Python指令碼實現Zabbix多行日誌監控過程解析
阿新 • • 發佈:2020-08-30
通過使用zabbix 日誌監控 我發現一個問題 例如oracle的日誌有報錯的情況 ,通常不會去手動清理 這樣的話當第二次有日誌寫進來的時候 zabbix的機制是回去檢查全部日誌,這樣的話之前已經告警過的錯誤日誌,又會被檢查到,這樣就會出現重複告警,而且zabbix的日誌監控只能讀到匹配當前行關鍵字的資料,感覺不太靈活,比如我想要匹配到的關鍵字之後再當前關鍵字的下N行再去匹配另一個關鍵字這個時候就比較麻煩,在這裡給大家推薦一個有效,便捷解決的方式。
通過Python指令碼實現日誌監控 要求 1 記錄指令碼檢查日誌位置,避免下次觸發指令碼的時候出現重複告警 2 關鍵字匹配支援正則 3 支援多個關鍵字查詢,例如第一個關鍵字匹配到當之後在這個關鍵字的下N行再去匹配第二個關鍵字 具體傳參格式
第一個引數是日誌路徑 第二個引數是關鍵字 第三個引數為 匹配到第一個表示式這種的關鍵字後再去地 N(2)行去匹配第二個關鍵詞(04030|02011)具體指令碼實現如下
import os import sys logtxt = "logtxt.txt" def read_txt(files,start_line): data = [] data.append("") with open(str(files) + "","r",encoding = 'UTF-8') as f: for line in f.readlines(): line = line.strip('\n')# 去掉列表中每一個元素的換行符 data.append(line) # 記錄本次的行數 wirte_log(len(data) - 1) if len(data) > start_line: return data[start_line - 1: ] else : print("開始行數大於文字檔案總行數!") def wirte_log(lines): global logtxt with open(logtxt,"w") as file: #”w "代表著每次執行都覆蓋內容 file.write(str(lines)) def read_log(): global logtxt if not os.path.exists(logtxt): with open(logtxt,"w") as file: #”w "代表著每次執行都覆蓋內容 file.write(str(1)) with open(logtxt + "",encoding = 'UTF-8') as f: s_lines = f.readlines() print("從第" + str(s_lines[0]) + "行開始") return s_lines[0] def deal_read_log(files,keyword,interval_line): keywords = keyword.replace("(","").replace( ")","").replace("'","").replace('"','"').split(',') start_keywords = keywords[0].split("|") end_keywords = keywords[1].split("|") start_line = read_log() lines_data = read_txt(files,int( start_line)) for_line = 1 while (for_line < len(lines_data)): #print(for_line) # print(lines_data[for_line]) # if end_keywords in lines_data[for_line]: #print(lines_data[for_line]) # print("-------------------") # for_line = for_line + 1 # else : isexist = 0 for sk in start_keywords: if sk in lines_data[for_line]: isexist = 1 break; if isexist == 1: #if start_keywords[0] in lines_data[ for_line] or start_keywords[1] in lines_data[for_line]: #當前行有end_keywords isexist2 = 0 for sk in end_keywords: if sk in lines_data[for_line]: isexist2 = 1 break; if isexist2 == 1: #print("行數=" + str(start_line - 1 + for_line) + "-" + str(start_line - 1 + for_line)) print(lines_data[for_line]) else : #當前行沒有end_keywords。 往下interval_line行去尋找 # 標記當前行數 flag_line = for_line count = 1 for_line = for_line + 1 while (for_line < len(lines_data)): isexist3 = 0 for sk in end_keywords: if sk in lines_data[for_line]: isexist3 = 1 break; if isexist3 == 1: #print("行數=" + str(start_line - 1 + flag_line) + "-" + str(start_line - 1 + for_line)) for prin in range(flag_line,for_line + 1): print(lines_data[prin]) break; for_line = for_line + 1 if count == int(interval_line): break; count = count + 1 for_line = for_line - 1 for_line = for_line + 1 if name == 'main': files = sys.argv[1] if '.log' in files: logtxt = files.replace(".log","_log.txt") else : logtxt = files.replace(".txt","_log.txt") # files = "ora.txt" keywords = sys.argv[2] # keywords = "'((04030|04000),ORA-)'" #上下關聯行數 interval_line = int(sys.argv[3]) # interval_line = 10 deal_read_log(files,keywords,interval_line)
接下來就是新增監控了
在agent的conf 檔案裡面新增UserParameter
到這裡監控就完成了
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。