Я использую Python Watchdog, чтобы отслеживать каталог для новых создаваемых файлов.В указанном каталоге создается несколько разных типов файлов, но мне нужно отслеживать только один тип файлов, поэтому я использую Watchdog PatternMatchingEventHandler
, где я задаю шаблон для мониторинга, используя ключевое слово patterns
.
Чтобы правильно выполнить код под капотом (здесь не отображается), мне нужно инициализировать пустой фрейм данных в моем обработчике событий, и у меня возникают проблемы с тем, чтобы заставить это работать.Если я уберу __init__
в приведенном ниже коде, все прекрасно работает, кстати.
Я использовал код в этот ответ в качестве вдохновения для моего собственного.
Код, который я настроил, выглядит следующим образом:
from watchdog.observers import Observer
from watchdog.events import PatternMatchingEventHandler
import time
import pandas as pd
import numpy as np
from multiprocessing import Pool
class HandlerEQ54(PatternMatchingEventHandler):
def __init__(self):
#Initializing an empty dataframe for storage purposes.
data_54 = pd.DataFrame(columns = ['Barcode','DUT','Step12','Step11','Np1','Np2','TimestampEQ54'])
#Converting to INT for later purposes
data_54[['Barcode','DUT']]=data_54[['Barcode','DUT']].astype(np.int64)
self.data = data_54
def on_created(self,event):
if event.is_directory:
return True
elif event.event_type == 'created':
#Take action here when a file is created.
print('Found new files:')
print(event.src_path)
time.sleep(0.1)
#Creating process pool to return data
pool1 = Pool(processes=4)
#Pass file to parsing function and return parsed result.
result_54 = pool1.starmap(parse_eq54,[(event.src_path,self.data)])
#returns the dataframe rather than the list of dataframes returned by starmap
self.data = result_54[0]
print('Data read: ')
print(self.data)
def monitorEquipment(equipment):
'''Uses the Watchdog package to monitor the data directory for new files.
See the HandlerEQ54 and HandlerEQ51 classes in multiprocessing_handlers for actual monitoring code. Monitors each equipment.'''
print('equipment')
if equipment.upper() == 'EQ54':
event_handler = HandlerEQ54(patterns=["*.log"])
filepath = '/path/to/first/file/source/'
# set up observer
observer = Observer()
observer.schedule(event_handler, path=filepath, recursive=True)
observer.daemon=True
observer.start()
print('Observer started')
# monitor
try:
while True:
time.sleep(5)
except KeyboardInterrupt:
observer.unschedule_all()
observer.stop()
observer.join()
Однако, когда я выполняю monitorEquipment
, я получаю следующее сообщение об ошибке:
TypeError: __init__() got an unexpected keyword argument 'patterns'
Очевидно, что я делаю что-то не так, когдаЯ инициализирую свой класс обработчика, но я рисую пробел относительно того, что это такое (что, вероятно, отражает мое неоптимальное понимание классов).Может кто-нибудь посоветовать мне, как правильно инициализировать пустой массив данных в моем классе HandlerEQ54
, чтобы не получить ошибку, которую я делаю?