Python - 在 subprocess.Popen 命令中使用变量

Question

这个问题已经有答案了:

Why does passing variables to subprocess.Popen not work despite passing a list of arguments? (6 个回答)

已关闭 1 年前。

我是编码新手，需要一些帮助。我正在编写一个 python 脚本，它将遍历目录的内容，并且当它遍历目录时，它将每个文件发送到蓝牙设备。

如果我指定文件名，它可以正常工作，但我无法通过使用文件名作为变量来使其工作。下面是代码

import os
import time
import subprocess

indir = '\\\\10.12.12.218\\myshare'
for  root, dirs, filenames in os.walk(indir):
   for file in filenames:
      print (file)
      subprocess.Popen('ussp-push /dev/rfcomm0 image1.jpg file.jpg', shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
print ('end') 

我试图用变量“file”替换命令中的“image1.jpg”，如下所示，但没有成功。

subprocess.Popen('ussp-push /dev/rfcomm0', file, 'file.jpg', shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)

非常感谢任何帮助。

Answer 1

有几个问题:

• shell=True 是不必要的。删除它并使用列表参数:

  import shlex
  
  args = shlex.split('ussp-push /dev/rfcomm0 image1.jpg file.jpg')
  

• 您正在尝试将命令行参数作为 Popen 的单独参数传递。使用 Popen(['echo', 'a']) 而不是 Popen('echo', 'a')。后者是完全错误的。请参阅Popen() function signature in the docs

• 不要使用 stdout=PIPE 和/或 stderr=PIPE 除非您从 p.stdout/ 读取p.stderr 管道，否则如果您的子进程填充了任何操作系统管道缓冲区，则它可能会永远阻塞

• 保存对 Popen() 的引用以稍后等待其状态。它是可选的，但有助于避免创建太多僵尸

您可以将文件生成部分提取到一个单独的函数中:

import os

def get_files(indir, extensions=('.jpg', '.png')):
    """Yield all files in `indir` with given `extensions` (case-insensitive)."""
    for root, dirs, files in os.walk(indir):
        for filename in files:
            if filename.casefold().endswith(extensions):
               yield os.path.join(root, filename)

然后并行执行每个文件的命令:

from subprocess import CalledProcessError, Popen

indir = r'\\10.12.12.218\myshare'
commands = [['ussp-push', '/dev/rfcomm0', path] for path in get_files(indir)]

# start all child processes
children = [Popen(cmd) for cmd in commands]

# wait for them to complete, raise an exception if any of subprocesses fail
for process, cmd in zip(children, commands):
    if process.wait() != 0:
       raise CalledProcessError(process.returncode, cmd)        

如果您不想并行运行命令，则只需使用 subprocess.call 而不是 subprocess.Popen:

import subprocess

indir = r'\\10.12.12.218\myshare'
statuses = [subprocess.call(['ussp-push', '/dev/rfcomm0', path])
            for path in get_files(indir)]
if any(statuses):
   print('some commands have failed')

它一次运行一个命令。