Очередь n8n растёт при работающих workers: как посчитать пропускную способность

Все workers выглядят живыми, но очередь заданий продолжает увеличиваться. Доступный процесс ещё не означает достаточную пропускную способность. Нужно сравнить скорость поступления работы со скоростью её фактического завершения.

Как разобрать ситуацию

Оцените длительность выполнения и полезную параллельность, затем проверьте ограничения внешних API и базы. Теоретическая скорость workers — только верхняя оценка: ожидания, конкуренция и большие задания уменьшают реальный поток. Добавление workers помогает лишь тогда, когда узкое место находится в доступной вычислительной мощности, а не в общем лимите поставщика.

Пример и ожидаемый результат

В учебной модели приходят 30 заданий в минуту. У каждого worker явно задана concurrency=1: один слот выполняет задание 5 секунд, то есть до 12 в минуту. Два таких worker дают два слота и до 24 завершений, поэтому очередь растёт минимум на 6 заданий в минуту.

Ожидаемый вывод модели: двух workers недостаточно для стабильного потока 30 в минуту. Третий даёт расчётные 36, но запас и реальную способность системы нужно подтвердить нагрузкой.

Проверка перед применением

• Измерьте завершённые задания, среднюю длительность и длительные хвосты по типам workflow.
• Проверьте возраст самой старой записи, а не только текущую длину очереди.
• После увеличения параллельности сравните ошибки 429, нагрузку базы и время каждого задания.

Разделите короткие интерактивные задания и тяжёлые пакетные импорты, если они мешают друг другу. Иначе средняя длительность выглядит терпимо, а конкретный пользователь ждёт за огромной выгрузкой. Масштабирование должно улучшать время получения полезного результата, а не только количество одновременно запущенных процессов в панели мониторинга.

Границы решения

Реальная конфигурация queue mode сложнее этой арифметики и зависит от версии n8n, Redis, базы и режима работы. Цифры учебные; настоящий кластер и нагрузочный тест здесь не запускались.

Если простые сценарии уже работают и нужна практика надёжных API-интеграций, проверок и обработки сбоев, посмотрите наш платный курс

Продвинутый n8n: production-автоматизации и AI-агенты. Перед записью сравните программу со своей задачей и подготовкой.

Техническая справка: docs.n8n.io: документация.

Следующий шаг: n8n в работе: разборы данных, сбоев и автоматизаций. По смежным вопросам: Webhook n8n создаёт дубли заявок: как спроектировать защиту от повтора, Пагинация API в n8n зациклилась: как проверить cursor и условие остановки.