Python - subprocess I/O operation on closed file

Habe ich versucht mit der Klasse unten, Befehle auszuführen, die in der Folge mit subporcess Modul in python2.6. 

from subprocess import Popen, PIPE

class BaculaActions():

    def __init__(self):
        self.console = Popen(["bconsole"], stdout=PIPE, stderr=PIPE, stdin=PIPE)

    def run_job(self, jobname, level):
        run = self.console.communicate("run job=%s level=%s yes" % (jobname, level))
        return(run)

    def del_jobid(self, jobid):
        delete = self.console.communicate("delete jobid=%s" % (jobid))
        return(delete)

Allerdings, wenn ich versuche den folgenden code, bekomme ich die Fehlermeldung:
ValueError: I /O operation on closed file 

from pconsole import BaculaActions

myconsole = BaculaActions()

run = myconsole.run_job("xxxxx-data", "incremental")
delete = myconsole.del_jobid(25487)

Jemand Idee was kann falsch sein?
Ich danke

InformationsquelleAutor adinanp | 2014-09-09
  1. 4

    Das Handbuch sagt eigentlich auch alles:

    Popen.communicate(input=None, timeout=None)
Interact with process: Send data to stdin. Read data from stdout and stderr, 
until end-of-file is reached. Wait for process to terminate.

    Führen Sie nach dem ersten Befehl aus und erhalten das Ergebnis, die 'bconsole" - Prozess hat beendet, die Rohre geschlossen sind und daher der Fehler in der zweiten communicate nennen.

    • Auf diese Weise dann die einzige Lösung wäre für jeden Befehl, den ich ausführen muss, instanziiere ich 'mysconsole' wieder? Ein weiterer Zweifel, da Popen nicht über eine "Methode" schließen Sie den Prozess gehe ich aus, es sind "verloren" in das system?
    • Der Prozess, den Sie beginnen, ist nicht verloren, es ist beendet (d.h. geschlossen). So haben Sie zwei Optionen: run 'bconsole" für jeden Befehl, den Sie senden möchten, und verwenden Sie communicate - das ist der sicherste Weg, es zu tun, oder wenn 'bconsole' zu lange dauert, zu starten, jedes mal, und falls Sie wissen genau, wie viel Leistung erzeugt wird, indem jeder Befehl, den Sie senden, können Sie das schreiben von Befehlen an stdin direkt und Lesen Sie die erwartete Anzahl der Zeilen von stdout/stderr - jedoch es ist leicht in die Sackgasse, und Sie müssen wissen, was Sie tun in diesem Fall.
    • Sie wollen wahrscheinlich pexpect - Modul, um die Kommunikation mit dem Kind-Prozess interaktiv wie in einem terminal. Siehe Warum man nicht einfach ein Rohr (popen())?
    InformationsquelleAutor isedev
  2. 0

    Dank an alle, die irgendwie versucht mir zu helfen.
    Als Lösung für das problem, ich habe die folgenden:

    class BaculaActions():

    def console(self):
        return(Popen(["bconsole"], stdout=PIPE, stderr=PIPE, stdin=PIPE))

    def run_job(self, jobname, level):
        run = self.console().communicate("run job=%s level=%s yes" % (jobname, level))
        return(run)

    def del_jobid(self, jobid):
        delete = self.console().communicate("delete jobid=%s" % (jobid))
        return(delete)

    def any_commands(self, command):
        any = self.console().communicate(command)
        return(any)

    Erstellte ich eine Methode "Konsole" und alle anderen Methoden meiner Klasse ich starten.

    Dies ist mein problem gelöst.

    Danke

    InformationsquelleAutor adinanp
  3. -2

    Bessere Weg ist, um zu tun, wie unten

    Jeder sub-Prozess-Initialisierung muss gekapselt werden versuchen Sie zu fangen, zu behandeln resource allocation Fehler. Dann wieder, wenn Erfolg.

    Bevor die Kommunikation gestartet wird, überprüfen Sie, ob der Kanal festgelegt ist (keine Fehler), dann kommunizieren.

    Beste Weg ist, um "Popen" auf die gleiche Stelle, egal wo Sie kommunizieren.Sie können am Ende duplizieren "Popen" zwei mal. Aber das ist sicher.

    Unbekannte interrupts zwischen "Popen" und "kommunizieren", wird Ihr python-job als Hänge ewig und müssen manuell töten. Dies ist sicherlich das, was wir nicht wollen, in der live -

    InformationsquelleAutor Haroon Rashedu
Schreibe einen Kommentar