У меня есть сценарий, в котором я запускаю команду popen a shell. Проблема в том, что сценарий не дожидается завершения выполнения этой команды popen и сразу же продолжает работу.
om_points = os.popen(command, "w")
.....
Как я могу сказать своему скрипту Python дождаться завершения команды оболочки?
В зависимости от того, как вы хотите работать со своим скриптом, у вас есть два варианта. Если вы хотите, чтобы команды блокировались и ничего не делали во время выполнения, вы можете просто использовать subprocess.call.
#start and block until done
subprocess.call([data["om_points"], ">", diz['d']+"/points.xml"])
Если вы хотите что-то делать во время выполнения или загружать данные в stdin, вы можете использовать communicate после вызова popen.
#start and process things, then wait
p = subprocess.Popen([data["om_points"], ">", diz['d']+"/points.xml"])
print "Happens while running"
p.communicate() #now wait plus that you can send commands to process
Как указано в документации, wait может заблокироваться, поэтому рекомендуется общаться.
subprocess.run() был добавлен в Python 3.5 и является рекомендуемым подходом к вызову подпроцессов.
- person LoMaPh; 23.09.2020
Вы можете использовать subprocess для этого.
import subprocess
#This command could have multiple commands separated by a new line \n
some_command = "export PATH=$PATH://server.sample.mo/app/bin \n customupload abc.txt"
p = subprocess.Popen(some_command, stdout=subprocess.PIPE, shell=True)
(output, err) = p.communicate()
#This makes the wait possible
p_status = p.wait()
#This will give you the output of the command being executed
print "Command output: " + output
Заставьте popen не продолжать, пока весь вывод не будет прочитан, выполнив:
os.popen(command).read()
Пусть команда, которую вы пытаетесь передать, будет
os.system('x')
затем вы превращаете это в заявление
t = os.system('x')
теперь питон будет ждать вывода из командной строки, чтобы его можно было присвоить переменной t.
Вам нужен метод wait.
wait - это метод класса subprocess.
- person Olivier Verdier; 16.05.2010
wait () у меня отлично работает. Подпроцессы p1, p2 и p3 выполняются одновременно. Таким образом, все процессы выполняются через 3 секунды.
import subprocess
processes = []
p1 = subprocess.Popen("sleep 3", stdout=subprocess.PIPE, shell=True)
p2 = subprocess.Popen("sleep 3", stdout=subprocess.PIPE, shell=True)
p3 = subprocess.Popen("sleep 3", stdout=subprocess.PIPE, shell=True)
processes.append(p1)
processes.append(p2)
processes.append(p3)
for p in processes:
if p.wait() != 0:
print("There was an error")
print("all processed finished")
Я думаю, что process.communicate () подойдет для вывода небольшого размера. Для большей производительности это не лучший подход.
