
正文
Python通过ssh连接服务器并执行命令
提示:扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
[本文出自天外归云的博客园]
脚本示例如下:
# coding:utf-8
import time,paramiko,re,StringIOdef exec_shell(command):
'''
command:传入的要执行的shell命令
'''
f = StringIO.StringIO()
header_match = '(\[.+?@.+?\s.+?\]\$)'
ssh.send(command+'\n')
while True:
out = ssh.recv(1024)
print out,
f.write(out)
header_list = re.findall(header_match, out)
if header_list and out.strip().endswith(header_list[-1]):
break
return fdef check_ip(content):
'''
从content中取出所有符合xx.120.xx.xx格式的ip地址(xx代表任意多数字)并返回
'''
ips = re.findall('\d+\.120\.\d+\.\d+',content)
return ipsif __name__ == '__main__':
'''
host:对应要连接的服务器ip
port:对应连接服务器的端口
username:对应访问服务器的用户名
'''
host = '10.120.143.70'
port = 8822
username = 'bjlantianyou'
'''
key_file为secureCRT对应的OpenSSH格式的私钥文件
可以在secureCRT的'Tools->Convert Private Key to OpenSSH Format...'选择相应的私钥文件转化为OpenSSH格式
例如:在Windows下保存到'E:\keys\'路径下,保存文件名为'id_rsa'
'''
key_file = 'E:\\keys\\id_rsa'
key = paramiko.RSAKey.from_private_key_file(key_file)
s = paramiko.SSHClient()
s.load_system_host_keys()
s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
s.connect(host, port, username, pkey=key)
ssh = s.invoke_shell()
'''
下面对应在secureCRT上执行命令的过程
'''
exec_shell('cd /home/project/api.winyyg.com')
out = exec_shell('ls')
ips = check_ip(out.getvalue())
exec_shell('cat '+ips[0]+'/log/duobao.log')
注意:缓冲区为空的情况下,ssh.recv(1024)会hang住。
可以进一步利用这个方法做一个自动化过滤log的工具或平台。







