Python-Log-Reader

Question

Ich versuche, eine asynchrone Funktion zu erstellen, die die ständig aktualisierende Protokolldatei liest und jede Zeile davon abruft. Das ist, was ich für jetzt habe:

async def log_reader(): 
    with open(LOG_PATH, "r", encoding='utf-8', errors='ignore') as logfile: 
     logfile.seek(0, os.SEEK_END) 
     while TRUE: 
      line = logfile.readline() 
      if not line: 
       await asyncio.sleep(0.2) 
       continue; 
      <do stuff> 

Es funktioniert gut, bis die Datei neu gestartet wird. Ich habe darüber nachgedacht zu prüfen, ob die Größe der Datei kleiner wurde als sie war, das würde bedeuten, dass sie aufgefrischt wurde, aber ich denke, dass es dafür eine bessere Option geben muss.

Alle Tipps sind willkommen.

Answer 1

Zum Aktualisieren der Datei können Sie deren Inode überprüfen. Holen Sie es aus dem Pfad mit os.stat und extrahieren Sie dann die inode number. Wenn der eingehende Inode anders ist als der vorherige, müssen Sie die Datei erneut öffnen. (Dies ist mit with Block möglicherweise nicht einfach)

Um es ein wenig zu optimieren, so dass Sie die Datei nicht die ganze Zeit abfragen, können Sie einige Zeitüberschreitung implementieren, die Sie leicht akzeptieren können, aber die höher als ist die übliche Verzögerung zwischen den Protokollzeilen.

Dies funktioniert, wenn die Datei ersetzt wurde, was die übliche Methode zum Rotieren von Logfiles ist. Es funktioniert nicht, wenn die Datei nur abgeschnitten wurde.