Я работаю над приложением Flask, которое должно непрерывно запускать процесс в фоновом режиме. Мне бы хотелось, чтобы у веб-приложения была возможность запускать и останавливать этот процесс в любое время.
Фоновая задача выполняет следующие действия:
- Загружает список файлов с внешнего сервера.
- Запускает задачу Celery для каждого файла для параллельной обработки файлов.
- После завершения обработки всех файлов перезапустите процесс (т. Е. Проверьте наличие новых файлов).
Часть, с которой я сейчас борюсь, - это как вручную запустить и остановить этот процесс. Celery отлично работает для выполнения всех задач, но я не нашел простого способа остановить / приостановить все запущенные задачи.
Есть ли лучший способ справиться с чем-то подобным с помощью Flask и Celery?