源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

python自动化工具日志查询分析脚本代码实现

  • 时间:2021-07-17 13:11 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:python自动化工具日志查询分析脚本代码实现
受控节点slave.py
[u]复制代码[/u] 代码如下:
import socket import re class Log(object):     file_list=['access.log','C:\\access.log']     master_ip='192.168.0.103'     def __init__(self):         s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)         s.bind(('',3333))         s.listen(1)         while True:             conn,addr=s.accept()             print addr[0]             if addr[0]==self.master_ip:                 reg=conn.recv(1024)                 result=self.all_log(reg)                 conn.sendall(result)             conn.close()     def all_log(self,reg):         logs=''         for f in self.file_list:             logs+='\n'+self.log_match(f,reg)         return logs     def log_match(self,f,reg):         log_result='------------------------'+f+'------------------------'+'\n'         fo=open(f,'r')         line=fo.readline()         rp=re.compile(reg)         while line!='':             log_match=rp.match(line)             if log_match:                 log_result+='\n'+log_match.group()             line=fo.readline()         return log_result if __name__=='__main__':     ds=Log()
主控节点master.py
[u]复制代码[/u] 代码如下:
import socket class SlvCluster(object):     ip_list=['127.0.0.1']     def __init__(self,reg):         for ip in self.ip_list:             self.single_slv(ip,reg)     def single_slv(self,slv_ip,reg):         s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)         s.connect((slv_ip,3333))         s.sendall(reg)         print '-----------------------'+slv_ip+'--------------------------'         print s.recv(102400)         s.close() if __name__=='__main__':     reg=raw_input('Input the regular expression:')     print '-----------Regular Expression: '+reg+'-----------------'     sc=SlvCluster(reg)
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部