logファイルの監視

Question

ログファイルを監視して、エラー文を発見したらbeep音+60秒経過でメール送信というプログラムを組んでいます。
watchdogでフォルダ内のログファイル（.log拡張子）が更新された後、
ログファイルの中の最終行を抜き取って【エラー】という文字列があれば
・処理1；logファイルに更新がなければ10秒毎にbeep関数呼び出しのループ
・処理２:６０秒間（６回）beep関数が呼び出されたらmail関数呼び出し
→logファイルに更新があればbeep関数呼び出しループから離脱
という処理を行いたいのですが、処理１～が組み方がいまいちわかりません。
【エラー】の文字列を発見した後の処理でループ？さらにその中でファイルの監視をする処理を挟む？のでしょうか？
組立のヒントをいただけたらありがたいです。
よろしくお願いします。

import time
import winsound
import win32com.client
import PySimpleGUI as sg
import os
import threading

from watchdog.events import FileSystemEventHandler
from watchdog.observers import Observer

def tail(fn, n, cnt):
    # ファイルを開いてすべての行をリストで取得する
    with open(fn, 'r', encoding="utf-8") as f:
        # 一行読む. 一行目はヘッダーだから結果は捨てる
        f.readline()
        # 全行読む
        lines = f.readlines()
        # 後ろからn行だけ返す
        if ("【エラー】" in str(lines[-n:])) == True:
            threading.Timer(10,beep(2000, 800)).start()
            #処理1；logファイルに更新がなければ10秒毎にbeep関数呼び出し
             # 処理２:６０秒間（６回）beep関数が呼び出されたらmail関数呼び出し
         
def beep(freq, dur=100):
    """
        ビープ音を鳴らす.
        @param freq 周波数
        @param dur  継続時間（ms）
    """
    # Windowsの場合は、winsoundというPython標準ライブラリを使います.

    winsound.Beep(freq, dur)
def mail(fn, error):
    outlook = win32com.client.Dispatch("Outlook.Application")

    mail = outlook.CreateItem(0)

    mail.to = '宛先１'
    # mail.cc = #cc1
    # mail.bcc = #bcc1
    mail.subject = 'test'
    mail.Attachments.Add(fn)
    mail.bodyFormat = 1
    mail.body = '''<自動送信メール>
    プログラム実行中にエラーが発生しました。
    エラー内容は下記の通りです。
    ''' + error

    mail.Send()
    print("メール送信完了")

# イベントハンドラ
class ChangeHandler(FileSystemEventHandler):

    # ファイルやフォルダが作成された場合
    def on_created(self, event):
        filepath = event.src_path
        filename = os.path.basename(filepath)
        print('%sを作成しました。' % filename)

    # ファイルやフォルダが更新された場合
    def on_modified(self, event):
        filepath = event.src_path
        filename = os.path.basename(filepath)
        cnt,lines = tail(filepath, 1, 0)
        window['-Multiline-'].print('%s :was changed.' % filepath, text_color='black')
        window['-Multiline-'].print(lines, text_color='black')
        #print('%s :was changed.' % filepath)

    # ファイルやフォルダが移動された場合
    def on_moved(self, event):
        filepath = event.src_path
        filename = os.path.basename(filepath)
        print('%sを移動しました。' % filename)

    # ファイルやフォルダが削除された場合
    def on_deleted(self, event):
        print(event)
        filepath = event.src_path
        print(filepath)
        filename = os.path.basename(filepath)
        print(filename)
        print('%sを削除しました。' % filename)

# 結果

folder_path = r"C:\Users\ookura\Desktop\testfolder"

# インスタンス作成
event_handler = ChangeHandler()
observer = Observer()

# フォルダの監視
observer.schedule(event_handler,folder_path, recursive=True)

# 監視の開始
observer.start()

cnt = 0



layout = [
#[sg.T("test")],
[sg.Multiline(size=(30,10),background_color="ivory", border_width=0, key='-Multiline-',autoscroll=True,auto_refresh=True)],
[sg.Text("exit",enable_events=True,key='exit')],
]
window = sg.Window('test',layout,background_color="ivory",no_titlebar=True,alpha_channel=0.5,font='メイリオ',keep_on_top=True, border_depth=0)
try:
    while True:
        event,values = window.read(timeout=10)

        if event is None:
            print('exit')
            break
        if event == "exit":
            break


except KeyboardInterrupt:

    # 監視の終了
    observer.stop()

    # スレッド停止を待つ
    observer.join()

    # 終了ログ
    print('フォルダ・ファイル監視スクリプトを終了します。')

Comments

[退会済みユーザー]

以下のシナリオの場合、どのような動作となるべきなのでしょうか？

[1] watchdogがログファイル（.log拡張子）が更新されたことを検知した
↓
[2] 更新されたログファイルの中の最終行を抜き取ったところ、【エラー】という文字列が含まれていた
↓
[3] 処理１（「その後のファイル更新を監視し、更新がなければ10秒間ごとにbeepする（6回beepするまでに更新があれば離脱する）」ループ処理）のループ開始

ここで、[３]のファイル監視中、logファイルが更新されたとします。
その更新内容が、「末尾に新たに【エラー】という文字を含む行が追加される」という内容（これをイベントAとします）であった場合、以下のいずれの動作となるべきですか？

・[1]～[3]を繰り返す　（→この場合[3]の「6回beepするまで」の条件は前から引き継ぐのか？リセットされるのか？）
・beep関数呼び出しループから離脱し、次に更新されたときまで、[1]~[3]は処理しない（＝イベントAは無視するということ）
・[3]の監視中に「末尾に新たに【エラー】という文字を含む行が追加される」という更新は絶対に起こりえない。
・その他

[ookura]

ご質問ありがとうございます。
ファイル更新があり、末尾が再度【エラー】の場合、1番目の選択肢の
[1]～[3]を繰り返す　（→この場合[3]の「6回beepするまで」の条件はリセットされる）という動作になります。

Answer 1

自分なら、タイマー処理用のスレッドをプログラム開始時に１つ生成し、定期的に行う処理は全部それに任せます。排他処理を考える必要がありますがとりあえずグローバル変数で処理イメージを書くと;

import os
import time
import threading

flag = 0                   # global変数 ログにエラーがあった時刻

# タイマースレッド
def timer_thread():
    print("thread開始")
    prev_flag = 0
    beep_count = 0

    while True:
        time.sleep(1)

        if flag > 0:
            if flag != prev_flag:   # 新しいエラーが発生していたら
                 prev_flag = flag
                 beep_count = 0
                 continue

            if time.time() > (prev_flag + beep_count * 10):
                 print("BEEP")
                 beep_count += 1

            if beep_count == 6:
                 print("MAIL")


# ログチェックに相当する処理（とりあえず"log.txt"の有無で代替)
def log_check():
    global flag
    if not os.path.exists("log.txt"):    # ファイルをチェック
        flag = 0
    else:
        if flag == 0:               # 上書き防止するため flagをチェック
            flag = time.time()      # 質問者は上書きする仕様なのでこれは暫定措置


th = threading.Thread(target=timer_thread)
th.start()
while True:
    log_check()
    time.sleep(2)

Comments

[ookura]

ご回答ありがとうございます。
丁寧にご説明いただき、どうすればいいかが見えてきました。
ちなみに、sleep操作について、GUI画面の固まりを防ぐ為、sleep処理以外の方法で
beepを行いたいのですが、その場合タイマー処理用スレッド内部で定期的に経過時間のカウントを行ってbeepさせるのが最良でしょうか？
お手数ですがご教示いただけますと幸いです。

[sigsegv]

sleep は GUI を固まらせないために入れてるので、gui が固まるというのは「スレッドを生成」というところが伝わってないような気がします。

回答に書いたコードをもう少し具体的に書きなおしました。
ログファイルからエラー文を探す代わりに、カレントディレクトリに log.txt というファイルが存在すれば、フラグをセットするようにしています。log.txt が存在すると、10秒ごとに BEEP を表示し、6回目で MAIL と表示します。

> 定期的に経過時間のカウントを行ってbeepさせるのが最良でしょうか？
定期的に関数を呼び出しする方法でも可能です。
その場合はカウントを覚えるグローバル変数なども必要になると思います。

[ookura]

連絡が遅くなりまして申し訳ありません。
ご教示いただいた内容で完全に欲しい動作が行えました。
スレッド生成について、知識不足だったのですが
おかげ様で新しく覚えることができました！ありがとうございました。