问题:如何在管道上使用`subprocess`命令
我想搭配subprocess.check_output()
使用ps -A | grep 'process_name'
。我尝试了各种解决方案,但到目前为止没有任何效果。有人可以指导我怎么做吗?
回答 0
要将管道与subprocess
模块一起使用,必须通过shell=True
。
但是,出于种种原因,这并不是真正可取的选择,其中不仅包括安全性。相反,请分别创建ps
和grep
流程,并将输出从一个管道传递到另一个管道,如下所示:
ps = subprocess.Popen(('ps', '-A'), stdout=subprocess.PIPE)
output = subprocess.check_output(('grep', 'process_name'), stdin=ps.stdout)
ps.wait()
但是,在您的特定情况下,简单的解决方案是先调用subprocess.check_output(('ps', '-A'))
然后str.find
在输出上。
回答 1
或者,您始终可以在子流程对象上使用communication方法。
cmd = "ps -A|grep 'process_name'"
ps = subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,stderr=subprocess.STDOUT)
output = ps.communicate()[0]
print(output)
通信方法返回标准输出和标准错误的元组。
回答 2
请参阅有关使用子流程设置管道的文档:http : //docs.python.org/2/library/subprocess.html#replacing-shell-pipeline
我没有测试下面的代码示例,但是它应该大致是您想要的:
query = "process_name"
ps_process = Popen(["ps", "-A"], stdout=PIPE)
grep_process = Popen(["grep", query], stdin=ps_process.stdout, stdout=PIPE)
ps_process.stdout.close() # Allow ps_process to receive a SIGPIPE if grep_process exits.
output = grep_process.communicate()[0]
回答 3
JKALAVIS解决方案很好,但是我将使用shlex代替SHELL = TRUE进行改进。下面即时查询时间
#!/bin/python
import subprocess
import shlex
cmd = "dig @8.8.4.4 +notcp www.google.com|grep 'Query'"
ps = subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,stderr=subprocess.STDOUT)
output = ps.communicate()[0]
print(output)
回答 4
另外,尝试使用'pgrep'
命令代替'ps -A | grep 'process_name'
回答 5
您可以在sh.py中尝试管道功能:
import sh
print sh.grep(sh.ps("-ax"), "process_name")
回答 6
在Python 3.5之后,您还可以使用:
import subprocess
f = open('test.txt', 'w')
process = subprocess.run(['ls', '-la'], stdout=subprocess.PIPE, universal_newlines=True)
f.write(process.stdout)
f.close()
该命令的执行被阻止,输出将在process.stdout中。
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。