Автоматизация мониторинга Celery на предмет аномальной длины очереди
Я использую Django/Celery/Redis для обработки задач, которые импортируют большие объемы данных в мою базу данных. Время от времени что-то идет не так, и рабочие, кажется, зависают. Мне интересно, есть ли способ отслеживать размер очередей внутри моего Django-приложения, чтобы я мог создать пользовательское оповещение.
Например, если моя очередь вырастет выше 100, я хотел бы создать предупреждение. Сейчас я просто периодически проверяю очереди через Redis CLI, но это не подходит. Я понимаю, что этот вопрос может быть неясным, поскольку здесь нет кода, но я просто не уверен, с чего начать.