1
#!/usr/bin/python
2
# -*- coding:utf-8 -*-
3

4
import paramiko
5

6
# 登录服务器，并执行代码
7
def sshclient_execmd(hostname, port, username, key, execmd):
8
  # paramiko 的操作日志，方便排查问题
9
  paramiko.util.log_to_file("paramiko.log")
10

11
  # 创建 SSHClient
12
  s = paramiko.SSHClient()
13
  s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
14

15
  # 这里是使用 rsa 登录的方式要传一个 privateKey 进来
16
  # 通过 key = paramiko.RSAKey.from_private_key_file(pkey)
17
  # 也可以使用账号密码的登录方式
18
  s.connect(hostname=hostname, port=port, username=username, pkey=key)
19

20
  #`执行命令得到输出
21
  stdin, stdout, stderr = s.exec_command(execmd)
22

23
  # 有些时候可能需要输入 Y 确定操作
24
  # stdin.write("Y")  # Generally speaking, the first connection, need a simple interaction.
25

26
  ## 读取输出
27
  output = stdout.read()
28

29
  ### 操作完毕需要关闭 client
30
  s.close()
31

32
  return output
33

34
  # 这里是根据输出做统计分析的代码
35
def statics(output):
36
  pass
37

38
def main():
39
  # 服务器相关的 SSH 信息
40
  hostnames = ['xxx', 'xxx', 'xxx']
41
  port = 22
42
  username = 'username'
43

44
  # 通过 RSA PrivateKey 文件读取 Key
45
  pkey = 'D:/id_rsa'
46
  key = paramiko.RSAKey.from_private_key_file(pkey)
47

48
  # 要执行的命令
49
  execmd = """free -h"""
50
  output = ""
51
  for hostname in hostnames:
52
      output += sshclient_execmd(hostname, port, username, key, execmd).
53
  # 将输出做分析处理
54
  statics(output)
55

56
if __name__ == "__main__":
57
  main()