python自动化工具日志查询分析脚本代码实现
2013-11-26 00:00
1256 查看
受控节点slave.py
主控节点master.py
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
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)
相关文章推荐
- python自动化工具日志查询分析脚本代码实现
- Solr/Lucene日志分析-查询热点词-脚本工具
- python 域名分析工具实现代码
- 使用python脚本实现查询火车票工具
- python脚本实现分析dns日志并对受访域名排行
- 能分析压缩的日志,且基于文件输入的PYTHON代码实现
- python脚本实现统计日志文件中的ip访问次数代码分享
- Python实现一个Git日志统计分析的小工具
- 用70行代码实现日志分析程序-python
- python脚本实现统计日志文件中的ip访问次数代码分享
- python写一个日志查询工具(登录ftp服务器得到日志并分析)
- 【脚本语言系列】关于Python代码分析工具line_profiler,你需要知道的事
- 用python脚本实现的android代码管理工具rrdt
- python脚本实现分析dns日志并对受访域名排行
- python刷投票的脚本实现代码
- 四款工具顺利实现 Python 与 JavaScript 间的代码转换
- python自动化配置脚本分析
- Python代码分析工具之dis模块
- MYSQL之pt-query-digest查询日志分析工具