Q&A
実現したいこと
watchdogモジュールを使って、ファイルが更新されたときに、処理を走らせたい
発生している問題・エラーメッセージ
ファイルが更新されたときに、処理を走らせたいのですが、1度の更新で複数回処理がよばれてしまっています。
ファイルは約10秒に一度、更新されます。
該当のソースコード
Python
1from time import sleep 2import os 3import shutil 4import datetime 5import soundfile as sf 6import numpy as np 7from multiprocessing import shared_memory 8from settings import * 9from analyze_recog_result import AnalyzeRecogResult 10from watchdog.observers import Observer 11from watchdog.events import PatternMatchingEventHandler 12 13rec_shm = shared_memory.SharedMemory(name=share_mem_name) 14rec_arr = np.ndarray(shape=(rec_sample_num), dtype=float, buffer=rec_shm.buf) 15 16class WatchdogHandler(PatternMatchingEventHandler): 17 def __init__(self, patterns): 18 super(WatchdogHandler, self).__init__(patterns=patterns) 19 self.start_sample = 0 20 21 def on_modified(self, event): 22 shutil.copyfile('temp/temp_rec_data_16k.wav', 'temp/copied_file.wav') 23 data, samplerate = sf.read(tmp_wav_path_copy) 24 rec_arr[self.start_sample:self.start_sample + len(data)] = data 25 self.start_sample = self.start_sample + len(data) 26 print(str(datetime.datetime.now().time())) 27 28 29 30if __name__ == "__main__": 31 event_handler = WatchdogHandler(['temp_rec_data_16k.wav']) 32 33 observer = Observer() 34 observer.schedule(event_handler, 'temp/', recursive=True) 35 observer.start() 36 37 try: 38 while True: 39 sleep(1) 40 finally: 41 observer.stop() 42 observer.join()
on_modified関数のprint文が以下のように表示されており、複数回呼ばれているようです。
06:40:32.536681
06:40:32.553222
06:40:32.572928
06:40:32.587926
処理を1度だけ走らせるには、どうしたらよいでしょうか。
回答1件
あなたの回答
tips
プレビュー
下記のような回答は推奨されていません。
このような回答には修正を依頼しましょう。