import re
import os
import paramiko
import redis
import time
tday_time=time.strftime("%Y-%m-%d", time.localtime()) # 获取当天的日期时间
file_path = '/Users/macbook/Desktop/log.txt' # 存放Log日志的路径
class ssh_Liunx():
'''连接服务器'''
def __init__(self,hostname,username,password): # 构造初始化数据
self.hostname = hostname
self.username = username
self.password = password
self.ssh =paramiko.SSHClient()
self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 用ssh连接远程主机时,第一次连接时会提示是否继续进行远程连接,选择yes
self.ssh.connect(self.hostname,22,self.username,self.password) #连接远程主机,SSH端口号为22
def ssh_comond(self,commonds): # 执行命令的方法
'''执行命令'''
stdin, stdout, stderr = self.ssh.exec_command(commonds) # 执行命令
result=stdout.readlines()
for line in result:
print(line)
return result
def get_hostname(self): # 获取服务器主机名
commonds='hostname'
get_hostname=self.ssh_comond(commonds)
return get_hostname
def get_disk_space(self): # 获取剩余磁盘空间
commonds='df -h'
get_diskspace=self.ssh_comond(commonds)
return get_diskspace
def Transcode(self):# 获取日志文件信息 输入到当前目录下
count=0 # 计数
commonds='cd /xxxx/logs;cat laravel-'+tday_time+'.log' # linux执行命令
get_transcode=self.ssh_comond(commonds) # 调用方法具体执行
for line in get_transcode: # 读取当前获取的日志信息
with open(file_path,'a+') as fp: # 本地生产log文件
fp.write(line) # 将日志另到文件中
count+=1
#print("当前文件总计:%s行日志信息"%count)
# print(os.path.getsize(file_path)) # 文件大小 字节
return get_transcode
def re_error(self): # 正则匹配日志的错误信息,存在问题,没有匹配出来,待继续处理
matches=[]
identifier_pattern = re.compile(r'Identifier: (.*?)$')
with open(file_path, 'a+') as fp:
for line in fp:
matches+=re.findall(identifier_pattern,line)
print("matches", matches)
def closed(self): # 关闭连接
self.ssh.close()
if name == 'main':
hostname = '127.0.0.1'
username = 'username'
password = 'password
ssh = ssh_test(hostname, username, password)
print(ssh.Transcode())
不完善之处还请多多指教