我尝试完成的任务是流式传输ruby文件并打印出输出.(注意:我不想一次打印出所有内容)
main.py
from subprocess import Popen, PIPE, STDOUT
import pty
import os
file_path = '/Users/luciano/Desktop/ruby_sleep.rb'
command = ' '.join(["ruby", file_path])
master, slave = pty.openpty()
proc = Popen(command, bufsize=0, shell=True, stdout=slave, stderr=slave, close_fds=True)
stdout = os.fdopen(master, 'r', 0)
while proc.poll() is None:
data = stdout.readline()
if data != "":
print(data)
else:
break
print("This is never reached!")
Run Code Online (Sandbox Code Playgroud)
ruby_sleep.rb
puts "hello"
sleep 2
puts "goodbye!"
Run Code Online (Sandbox Code Playgroud)
问题
流文件工作正常.hello/goodbye输出以2秒延迟打印.正如脚本应该工作.问题是readline()最后会挂起而永不退出.我从未到过最后一个印刷品.
我知道有很多这样的问题,这里有一个stackoverflow但是没有它们让我解决问题.我不是那个整个子流程的东西,所以请给我一个更实际/具体的答案.
问候
编辑
修复意外的代码.(与实际错误无关)
在Machine1上,我有一个Python2.7脚本,它在RAM中计算一个大的(最多10MB)二进制字符串,我想写入Machine2(一台远程机器)上的磁盘文件.做这个的最好方式是什么?
约束:
这两台机器都是Ubuntu 13.04.它们之间的连接很快 - 它们位于同一网络上.
Machine2上可能尚不存在目标目录,因此可能需要创建目标目录.
如果这很容易,我想避免将字符串从RAM写入Machine1上的临时磁盘文件.这是否会消除可能使用系统调用rsync的解决方案?
因为字符串是二进制的,所以它可能包含可以解释为换行符的字节.这似乎排除了可能在Machine2上使用对echo命令的系统调用的解决方案.
我希望这在Machine2上尽可能轻量级.因此,我想避免在Machine2上运行ftp等服务或在那里进行其他配置活动.另外,我不太了解安全性,因此除非确实有必要,否则我们希望避免打开其他端口.
我在Machine1和Machine2上设置了ssh密钥,并希望将它们用于身份验证.
编辑:Machine1正在运行多个线程,因此有可能多个线程可能会在重叠时间尝试写入Machine2上的同一文件.我不介意在这种情况下将文件写入两次(或更多)所导致的低效率,但Machine2上的结果数据文件不应被同时写入损坏.也许需要在Machine2上锁定操作系统?
我正在寻找一个rsync解决方案,因为它是一个我自己理解得很好的自包含实体,并且不需要在Machine2上进行配置.
我想从Python脚本启动一个交互式SSH终端而不使用像pexpect或paramiko这样的模块 - 我想坚持使用CentOS预装的Python为我提供的功能(以简化兼容性和部署问题).
我可以使用子进程模块运行命令,但无法获得交互式终端.在Perl中,我只是使用反引号来实现这一目标,但我正在寻找pythonic的方法.
有人能指出我正确的方向吗?
更新 - 根据@ leoluk的回答,我使用docs.python.org中的说明提出:subprocess.call("ssh ...", shell=True)