python pexpect 启动、与子进程交互的例子--logstash

import pexpect,sys

child = pexpect.spawn(‘/home/cf/elk/Summoner/Elk/logstash/test/bin/logstash -f /home/cf/elk/Summoner/Elk/logstash/test/conf.d‘, timeout=60)

#index = child.expect([‘startup completely‘, pexpect.TIMEOUT])
while True:
    index = child.readline()
    sys.stdout.write(index)
    sys.stdout.flush()
    if index == ‘Logstash startup completed\r\n‘:
        break

n = child.send(‘hello\nworld‘)
output = ""
while True:
    index = child.readline()
    output += (index)
    if index == ‘}\r\n‘:
        break
sys.stdout.write(output)
sys.stdout.flush()

#child.kill(15)
#index = child.readline()
#print index


#child.kill(15)
#index = child.readline()
#print index

child.close(force=True)
print ‘closed‘