erjemin/2023_tacacs_watcher
erjemin/2023_tacacs_watcher
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ловит события "модификация файла"

Browse Source
This commit is contained in:
Sergei Erjemin 2023-12-19 18:35:06 +03:00
parent f974249f00
commit 168d7cc1f8
1 changed files with 53 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
main.py
View File

@ -1,8 +1,10 @@
# -*- coding: utf-8 -*-
import platform
import time
import sys
import signal
import toml
import os
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
from pathlib import Path
@ -33,8 +35,28 @@ def read_toml(file_path):
sys.exit(1)
class LogFileHandler(FileSystemEventHandler):
def __init__(self, log_filename):
self.log_filename = log_filename
def on_modified(self, event):
if event.is_directory:
return
print(event)
# elif event.event_type == 'modified' and event.src_path == self.log_filename:
# # Обработка изменений в лог-файле
# with open(event.src_path, 'r') as file:
# new_lines = file.readlines()
# # Обработка новых строк
# for line in new_lines:
# print(f"Изменение в {self.log_filename}:: {line}", end='')
# Press the green button in the gutter to run the script.
if __name__ == '__main__':
# Получение информации о системе
# system_info = platform.system()
# print(f"System: {system_info}")
# Установка обработчика сигнала
signal.signal(signal.SIGTERM, handler_stop)
# Считывание имени config-файла их аргументов командной строки
@ -49,8 +71,36 @@ if __name__ == '__main__':
interval = config['interval'] if 'interval' in config else 1
# получаем все группы в конфиге
group_keys = [key for key, value in config.items() if isinstance(value, dict)]
count_valid_groups = 0
observers = []
for group in group_keys:
print(group)
if 'log_in' not in config[group]:
print(f"Config '{config_file}' not have key 'log_in' in group '{group}' (see config '{config_file}').")
continue
if not os.path.isfile(config[group]['log_in']):
print(f"File '{config[group]['log_in']}' not exist (see config '{config_file}').")
continue
if 'outdir' not in config[group]:
print(f"Config '{config_file}' not have key 'outdir' in group '{group}' (see config '{config_file}').")
continue
if not os.path.isdir(config[group]['outdir']):
print(f"Directory '{config[group]['outdir']}' not exist (see config '{config_file}').")
continue
observers.append(Observer())
observers[count_valid_groups].schedule(LogFileHandler(config[group]['log_in']),
path=os.path.dirname(config[group]['log_in']),
recursive=False)
observers[count_valid_groups].start()
count_valid_groups += 1
# observer = Observer()
# event_handler = LogFileHandler(config[group]['log_in'])
# observer.schedule(event_handler, path=os.path.dirname(config[group]['log_in']), recursive=False)
if count_valid_groups == 0:
# если нет ни одной валидной группы, то выходим
print(f"Config '{config_file}' not have valid groups (see config '{config_file}').")
sys.exit(1)
# все обработчики в этом цикле
try:
@ -59,6 +109,8 @@ if __name__ == '__main__':
print_hi('PyCharm')
time.sleep(interval)
except KeyboardInterrupt:
for observer in observers:
observer.stop()
print('Terminate by `KeyboardInterrupt`.')
sys.exit(0)
except ValueError: