python: pexpect "OSError: [Errno 5] Input/output error"

Chowroc

求教，使用 pexpect 结果的情况如下，不知道是什么原因：

>>> foo = pexpect.spawn('scp root@192.168.126.11 /tmp')
>>> foo.logfile = sys.stdout
>>> foo.expect('.*password:')
root@192.168.126.11's password: 0
>>> foo.sendline('symqfct')  
symqfct
8
>>> foo.interact()


expect-5.42.1-1.i386.rpm                      100%  148KB 147.7KB/s   00:00   

Traceback (most recent call last):
  File "<stdin>", line 1, in ?
  File "/usr/lib/python2.3/site-packages/pexpect.py", line 1062, in interact
    self.__interact_copy(escape_character)
  File "/usr/lib/python2.3/site-packages/pexpect.py", line 1086, in __interact_copy
    data = self.__interact_read(self.child_fd)
  File "/usr/lib/python2.3/site-packages/pexpect.py", line 1075, in __interact_read
    return os.read(fd, 1000)
OSError: [Errno 5] Input/output error

谢谢

弥敦路九号

你用SSH协议不是可以用证书登录吗？

Chowroc

那么在 python 中如何实现呢？我试过 paramiko 模块，但不太方便，而且在传输大量文件时，中间挂起。

弥敦路九号

你最终想实现什么目的呢

Chowroc

最终就是要实现能够定时使用 ssh 从远端取得文件，比如日志，每小时或每天。但是需要使用 python。

我现在的实现如下：

1. 
   
2. #!/usr/bin/python
   
3. # -*- encoding: UTF-8 -*-
   
4. 
   
5. import os
   
6. import time
   
7. import pexpect
   
8. import tarfile
   
9. 
   
10. class ft_handler:
    
11.         def __init__(self, info):
    
12.                 self.user = info['user']
    
13.                 self.host = info['host']
    
14.                 self.passwd = info['passwd']
    
15.                 self.method = info['method']
    
16.                 self.regexp = info['regexp']
    
17.                 self.srcdir = info['srcdir']
    
18.                 self.dstdir = info['dstdir']
    
19.                 self.files = info['files']
    
20. 
    
21.         def getfile(self, srcdir = '', dstdir = '', files = ''):
    
22.                 if srcdir:      self.srcdir = srcdir
    
23.                 if dstdir:      self.dstdir = dstdir
    
24.                 if files:       self.files = files
    
25. 
    
26.                 if self.method == 'ssh.pexpect':
    
27.                         cmd = 'ssh %s@%s "cd %s; find . | grep %s >tmplist; tar -T tmplist -c -z -f tmp.tgz"' \
    
28.                                 % (self.user, self.host, self.srcdir, self.files)
    
29.                         self.ssh_pexpect(cmd, 300)
    
30. 
    
31.                         if not os.path.isdir(self.dstdir):  os.makedirs(self.dstdir)
    
32.                         cmd = 'scp %s@%s:%s/tmp.tgz %s/' % (self.user, self.host, self.srcdir, self.dstdir)
    
33.                         self.ssh_pexpect(cmd, 600)
    
34. 
    
35.                         cmd = 'ssh %s@%s "cd %s; rm tmplist tmp.tgz"' % (self.user, self.host, self.srcdir)
    
36.                         self.ssh_pexpect(cmd)
    
37. 
    
38.                         tar = tarfile.open('%s/tmp.tgz' % self.dstdir, 'r:gz')
    
39.                         for T in tar:  tar.extract(T, self.dstdir)
    
40. 
    
41.                         os.remove('%s/tmp.tgz' % self.dstdir)
    
42. 
    
43.                 # elif self.method == 'ssh.paramiko':
    
44. 
    
45.         def ssh_pexpect(self, cmd, timeout=30):
    
46.                 print cmd
    
47.                 T = time.time()
    
48.                 ssh = pexpect.spawn(cmd, timeout=timeout)
    
49.                 ssh.expect(['password: '])
    
50.                 ssh.sendline(self.passwd)
    
51.                 ssh.expect(pexpect.EOF)
    
52.                 # ssh.sendeof()
    
53.                 ssh.close()
    
54.                 print '%d seconds' % int(time.time() - T)
    

复制代码

Chowroc

最后使用一个 expect(pexect.EOF)，而不是使用 interact()。不过这里有一个超时的问题，超时后会抛出异常并终止。