windows上使用paramiko模拟ssh执行命令问题

killedman

1. #!/usr/bin/env python3
   
2. #-*- coding:utf-8 -*-
   
3. #stop dpat
   
4. 
   
5. import paramiko
   
6. import time
   
7. 
   
8. username='username'
   
9. password='password'
   
10. ip='192.168.1.1'
    
11. 
    
12. #建立连接
    
13. ssh = paramiko.SSHClient()
    
14. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    
15. ssh.connect(hostname=ip, port=22, username=username, password=password,timeout=10)
    
16. #打印分隔符
    
17. print('  Server: ' + ip)
    
18. 
    
19. stdin, stdout, stderr = ssh.exec_command("jstorm list|grep -A 1 dpat-test|grep status")
    
20. test_name = stdout.readline()
    
21. print(test_name)
    
22. 
    
23. 
    
24. #stop dpat-test,while循环直到状态由ACTIVE变为KILLED
    
25. while('ACTIVE' in test_name):
    
26.     time.sleep(1)
    
27.     #一直想不通执行该命令后为什么没有效果，尝试使用while循环去一遍遍执行，

复制代码

stdin, stdout, stderr = ssh.exec_command('cd /run/ayena/dpat/;sh stop-dpat.sh')
这样代码执行总是没有效果，即时更改为
stdin, stdout, stderr = ssh.exec_command('cd /run/ayena/dpat/;sh stop-dpat.sh'，timeout=10)
也没有效果，感觉timeout=10在这里没有效果
大家有什么建议吗，能看出来哪里有问题？


版本信息：
win7
python3.5
D:\python3.5\Lib\site-packages\paramiko 2.1.1

799029078

print stderr

killedman

799029078 发表于 2017-05-18 07:04
print stderr

print(stderr.read())是空值

baby_神

test_name = stdout.read()

killedman

baby_神 发表于 2017-05-18 19:01
test_name = stdout.read()

有什么区别？和readline

killedman

1. #!/usr/bin/env python3
   
2. #-*- coding:utf-8 -*-
   
3. #stop dpat
   
4. 
   
5. import paramiko
   
6. import time
   
7. 
   
8. username='username'
   
9. password='password'
   
10. ip='192.168.1.1'
    
11. 
    
12. #建立连接
    
13. ssh = paramiko.SSHClient()
    
14. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    
15. ssh.connect(hostname=ip, port=22, username=username, password=password,timeout=10.0)
    
16. #打印分隔符
    
17. print('  Server: ' + ip)
    
18. 
    
19. stdin, stdout, stderr = ssh.exec_command("jstorm list|grep -A 1 dpat-test|grep status")
    
20. test_name = stdout.readline()
    
21. print(test_name)
    
22. 
    
23. 
    
24. #stop dpat-test,while循环直到状态由ACTIVE变为KILLED
    
25. #while('ACTIVE' in test_name):
    
26. if('ACTIVE' in test_name):
    
27.     print(time.asctime(time.localtime(time.time())))
    
28.     stdin, stdout, stderr = ssh.exec_command('cd /run/ayena/dpat/;sh stop-dpat.sh')
    
29.     #神奇的5秒钟，上一条命令添加timeout参数不知道为什么不起作用
    
30.     time.sleep(5)
    
31.     print(time.asctime(time.localtime(time.time())))
    
32.     stdin, stdout, stderr = ssh.exec_command('jstorm list|grep -A 1 dpat-test|grep status')
    
33.     print(stderr.read())
    
34.     test_name = stdout.readline()
    
35.     print(test_name)
    
36. 
    
37. print("begin  stoping run-dpat: "  + time.asctime(time.localtime(time.time())))
    
38. while('KILLED' in test_name):
    
39.     time.sleep(10)
    
40.     stdin, stdout, stderr = ssh.exec_command('jstorm list|grep -A 1 dpat-test|grep status')
    
41.     test_name = stdout.readline()
    
42. if test_name is '':
    
43.     print(" end  stoping dpat-test : "  + time.asctime(time.localtime(time.time())))
    
44.     print('stop dpat-test process success')
    
45. #关闭连接
    
46. ssh.close()

复制代码

killedman

回复 6# killedman
    #神奇的5秒钟，上一条命令添加timeout参数不知道为什么不起作用
    time.sleep(5)