如何将 rfcomm shell 命令的结果放入 python 中的变量中？

Question

我在python中使用这个脚本来连接蓝牙设备然后获取数据，但是我想知道这个shell命令的结果以便做下一步工作

import os
import time
import signal
import subprocess


p = subprocess.Popen("sudo rfcomm connect /dev/rfcomm0 XX:XX:XX:XX:XX:XX 1",shell=True)
(stderr,stdout) = p.communicate()
print 'stderr: [%s]' % stderr
print 'stdout: [%s]' % stdout
time.sleep(5)
while True:
     print "Device is ready"
     time.sleep(5)

此代码是我运行命令时的示例：

"sudo rfcomm connect /dev/rfcomm0 XX:XX:XX:XX:XX:XX 1" 

在shell中，它返回：

Connected /dev/rfcomm0 to XX:XX:XX:XX:XX:XX on channel 1
Press CTRL-C for hangup

但是我怎样才能把上面的结果放在一个变量中，因为我需要知道这个命令的结果？ 我在子进程中使用 stdout、stderr 但不起作用。 我正在使用 python 2.7

Python subprocess and user interaction

在link 上面讨论了在一般变量中获取输出，但我的问题中与 rfcomm 相关的问题，它没有将其结果放入变量中，我运行这些脚本并且它们运行良好，但它不起作用当它与 rfcomm 命令一起使用时

Answer 1

如果您使用的是 Python 3.5 或更高版本， 您可以改用run。这样你就可以直接访问了，

result = subprocess.run(["sudo rfcomm connect /dev/rfcomm0 XX:XX:XX:XX:XX:XX 1"], stdout=subprocess.PIPE)

然后像这样访问你想要的，

result.stdout

如果您使用 Python 2.7，正如我链接的文档所建议的那样，他们会将您重定向到 Older high-level API 部分。 从那里你会注意到你可以使用check_output

result = subprocess.check_output(["sudo rfcomm connect /dev/rfcomm0 XX:XX:XX:XX:XX:XX 1"])

注意，如果您想捕获错误，也请使用 stderr=subprocess.STDOUT 标志。

result = subprocess.check_output("sudo rfcomm connect /dev/rfcomm0 XX:XX:XX:XX:XX:XX 1", stderr=subprocess.STDOUT, shell=True)

最后，有一个重要的事情你不应该知道，

默认情况下，此函数会将数据作为编码字节返回。输出数据的实际编码可能取决于被调用的命令，因此通常需要在应用程序级别处理对文本的解码。

编辑

因为您的目标似乎是在运行时获得输出。看看这个answer。我更喜欢链接而不是重新发明轮子。

Answer 2

您可能需要在返回数据之前发出 CTRL+C 命令。

发送信号并捕获异常以处理返回的内容。

import os
import time
import signal
import subprocess


stream = []
try:
    p = subprocess.Popen("sudo rfcomm connect /dev/rfcomm0 XX:XX:XX:XX:XX:XX 1",shell=True)
    #(stderr, stdout) = p.communicate()

    #print 'stderr: [%s]' % stderr
    #print 'stdout: [%s]' % stdout
    #time.sleep(5)
    #print "Device is ready"

    time.sleep(5)

    os.kill(p.pid, signal.CTRL_C_EVENT)
    p.wait()

except KeyboardInterrupt:                
#except Exception: 
    for line in p.stdout: #May also be p.stderr
        stream.append(line)                         

    for x in stream:                    
        print(x)