Отслеживание файлов и передача данных в aiogram

Стоит задача отслеживать появление видео в разных домашних папках пользователей linux, и регулярно отправлять видео в бота aiogram. Причем отслеживание нужно начинать только с того момента, когда пользователь создал папку (нажал кнопку создать папку в боте). Сначала написал простой скрипт на innotify, который рекурсивно отслеживает изменения в папке /home и отправляет на flask сервер запрос с данными об изменении

watcher.py

from inotify.constants import IN_ATTRIB 
from config import BASE_PATH, ENDPOINT_URL
import requests


i = inotify.adapters.InotifyTree("/home/ftp/", mask=IN_ATTRIB )

for event in i.event_gen(yield_nones=False):
    (_, type_names, path, filename) = event
    if "IN_ATTRIB" in type_names:
        data = {
            "type": type_names[0],
            "path": path,
            "file": filename
        }

    requests.post(ENDPOINT_URL, json=data)

flask сервер же добавляет в бд запись об ивенте. Хотел настроить celery beat но проблема в том, что в celery нельзя динамически добавить задачу, которая будет выполняться по расписанию без перезапуска celery Мне кажется это не очень подход, может кто подскажет решения лучше?


Ответы (0 шт):