Comment utiliser la sortie en cours d'exécution de la console dans un autre programme

Il semble que vous vouliez des tuyaux. Les tuyaux prennent la sortie standard d'un programme et la transmettent directement au suivant. L'exemple le plus simple auquel je puisse penser:

import sys
while True:
    line = sys.stdin.readline()
    # do something with line

C'est facile à retenir car l'opérateur de tube ressemble un peu à un tube |

En savoir plus tuyaux: http: //web.cse.ohio-state .edu / ~ mamrak.1 / CIS762 / pipes_lab_notes.html

Edit: utiliser sys.stdin pour lire les tuyaux pour toujours est bien expliqué ici

Le modèle important à en tirer se trouve juste là:

ls | grep ".bin"

Vous pouvez créer quelque chose comme tail en python. Ceci est un exemple de code mais ne peut pas gérer si le fichier est supprimé.

def tail_F(some_file):
    while True:
        try:
            for line in sh.tail("-f", some_file, _iter=True):
                yield line
                # do whatever with new line
        except sh.ErrorReturnCode_1:
            yield None

Vous pouvez obtenir ce résultat de plusieurs manières.

Sur un système Unix, la plus simple, je crois, serait l'utilisation de tuyaux Disons que vous avez program1 (p1) qui génère des données et programme2 (p2) qui lit et utilise ces données.

Vous pouvez diriger la sortie de p1 vers p2 comme suggéré par @Charles Landau en utilisant | qui crée un tube entre le stdout et le stdin des 2 programmes

mkfifo 1
shell1: tail -f 1
shell2: echo "Hello!" > 1

Si vous souhaitez également visualiser la sortie de p1, vous pouvez utiliser tee qui prend le stdin et le transfère vers le stdout et vers un programme

import os
import sys

FIFO="/tmp/test_fifo"

if not os.path.exists(FIFO):
    exit()

f = open( FIFO, "r")

while 1:
    read_fifo = f.readline()
    print( read_fifo, end='')
    sys.stdout.flush()

Maintenant, cela ne fonctionnera que si vous avez l'intention de lancer p1 et p2 en même temps (à quel point un pense qu'il serait préférable d'en faire un seul programme). Une utilisation plus générique du tube serait pour p1 de créer un tube nommé (FIFO) et pour p2 de lire à partir de ce tube:

p1.py (serveur)

import os
from random import randint
import time

FIFO="/tmp/test_fifo"

if not os.path.exists(FIFO):
    os.mkfifo(FIFO)

pipe = os.open( FIFO, os.O_RDWR) #I use this to avoid the program hanging on this step.
                                 #When you open a FIFO, the behavior is blocking, meaning that the program will hang until both end (r/w) of the pipe are being used
f = os.fdopen( pipe, "w")        #Then i want a file object so i can flush it

while 1:
    # Do operation
    output = randint(0,999999)
    # Print output
    print(output)

    # Send output into pipe
    f.flush()
    f.write( str(output) + '\n')
    time.sleep(0.5)

f.close()
pipe.close()

os.unlink(FIFO)