Sie müssen möglicherweise einen wait
auf Ihrem Subprozess aufrufen und dann (einmal durchgeführt) den Status im Feld returncode
der Subprozessinstanz überprüfen.
Ich habe eine kleine Routine, die Sachen nennt, wird es vielleicht ... helfen
def singleProcessExecuter(command, ** kwargs):
assert isinstance(command, list), "Expected 'command' parameter to be a list containing the process/arguments to execute. Got %s of type %s instead" % (command, type(command))
assert len(command) > 0, "Received empty list of parameters"
retval = {
"exitCode": -1,
"stderr": u"",
"stdout": u"",
"execTime": datetime.timedelta(0),
"command": None,
"pid": None
}
retval["command"] = command
log.info("::singleProcessExecuter > At %s, executing \"%s\"" % (datetime.datetime.now(), " ".join(command)))
#print("::singleProcessExecuter > At %s, executing \"%s\"" % (datetime.datetime.now(), " ".join(parameter)))
cwd = kwargs.get("cwd", os.getcwd())
user = kwargs.get("user", getUid())
sheel = kwargs.get("shell", False)
startDatetime = datetime.datetime.now()
myPopy = subprocess.Popen(command, cwd=cwd, preexec_fn=os.seteuid(getUid(user)), shell=sheel, stdout=subprocess.PIPE, stderr=subprocess.PIPE, stdin=subprocess.PIPE)
retval["pid"] = myPopy.pid
log.debug("::singleProcessExecuter > Command \"%s\" got pid %s" % (" ".join(command), myPopy.pid))
try:
retval["stdout"], retval["stderr"] = myPopy.communicate()
myPopy.wait()
except OSError, osErr:
log.debug("::singleProcessExecuter > Got %s %s in myPopy.communicate() when trying get output of command %s. It is probably a bug (more info: http://bugs.python.org/issue1731717)" % (osErr, type(osErr), command[0]))
except Exception, e:
log.warn("::singleProcessExecuter > Got %s %s when trying to get stdout/stderr outputs of %s" % (type(e), e, " ".join(command)))
log.debug("::singleProcessExecuter > Got %s %s when trying to get stdout/stderr outputs of %s. Showing traceback:\n%s" % (type(e), e, " ".join(command), traceback.format_exc()))
raise
retval["exitCode"] = myPopy.returncode
retval["execTime"] = datetime.datetime.now() - startDatetime
#print(":singleProcessExecuter > This is %s's retval:\n%s" % (" ".join(parameter), retval))
return retval
Sie können es versuchen, mit:
print "This is the return: %s" % singleProcessExecuter(["ls", "-la"])
ist '' wait'' wirklich erforderlich oder '' communicate() '' '' von Dingen, wenn der Prozess noch läuft? – user248237dfsf
@ user248237 Die Dokumentation sagt "Rückkehrcode, eingestellt durch' poll() 'und' wait() '(und indirekt durch' communicate() ')." So sollte 'communicate()' sich darum kümmern, auf den Prozess zu warten. –