我需要打开一个R脚本并为其提供由单独的python脚本制定的输入.该subprocess模块似乎是一个很好的方法来做到这一点.
我遇到了一些令人费解的结果,即我可以写一次,只能写一次p.stdin.这是我到目前为止:
from subprocess import Popen, PIPE, STDOUT
p = Popen(['r --no-save'],stdin=PIPE,stdout=PIPE,stderr=PIPE,shell=True)
p.stdin.write("source('myrscript.R')\n")
p.stdin.write('myfirstinput')
Run Code Online (Sandbox Code Playgroud)
运行此代码时会发生的情况是第一个stdin.write()按预期执行的实例(并打开我的R脚本),但第二行什么都不做,并且子进程(实际上是R脚本)退出时出现错误,表明子进程在预期输入并因此终止的情况下没有收到输入.
注意 - 在一个完美的世界中,我只是直接通过R进行交互,但是这个特殊的脚本需要复杂的输入,不能直接输入用于实际目的.此外,rpy/rpy2不是一个选项,因为此脚本的最终用户不一定有权访问该模块或其依赖项.rscript也不是一种选择(出于很多原因,但主要是因为最终用户R配置的可变性).
最后,p.communicate不是一个选项,因为显然会在写完后关闭这个过程,我需要保持它开放.
提前致谢
在下面的示例代码中,我想要生成一个指示,表明预定义的数字列表是否与我正在循环的迭代匹配或不匹配.这是我的问题的简化示例.
不幸的是,我的代码不符合我的期望,可能我错过了一些简单的东西.在我的实际应用中,这是通过具有不同输出的极大的一维阵列来完成的,但是这以简单的文本方式展示了它,易于重现.
也许我还应该补充说我正在使用Python 2.7.5.
match = [1, 3, 4]
volumes=10
def vector_covariates(match, volumes):
for i in range(volumes):
if i == match:
print "[*]"
else:
print "[ ]"
vector_covariates(match, volumes)
Run Code Online (Sandbox Code Playgroud)
运行时,输出:
[ ]
[ ]
[ ]
[ ]
[ ]
[ ]
[ ]
[ ]
[ ]
[ ]
Run Code Online (Sandbox Code Playgroud)
而"正确"的输出应该是
[*]
[ ]
[*]
[*]
[ ]
[ ]
[ ]
[ ]
[ ]
[ ]
Run Code Online (Sandbox Code Playgroud)