Предотвращение одновременных запусков рабочих процессов с использованием Redis

Гарантируйте, что ваш рабочий процесс выполняется только один раз одновременно, устанавливая блокировки в Redis, чтобы рано остановить дубликаты с ясными ошибками для защиты данных и избежания превышения лимитов частоты. Следите за прогрессом работы в режиме реального времени с помощью понятных меток («в работе», «загрузка», «завершение») для бесшовного отслеживания и опроса статуса. Идеально подходит для сценариев, когда вебхуки, cron-задачи или вложенные рабочие процессы запускают много процессов параллельно — нет необходимости создавать отдельную очередь. Легко настраивайте TTL, метки прогресса и обработку ошибок, а также интегрируйте уведомления в Slack/по электронной почте. Отличное решение для управления всплесками обратных вызовов Telegram, защиты лимитов частоты внешних…

Category: n8n

Описание
Отзывы (0)

Описание

Этот рабочий процесс разработан для предотвращения одновременных исполнений одной и той же продолжительной задачи, используя Redis в качестве механизма блокировки. Это гарантирует, что только один экземпляр рабочего процесса выполняется за раз для данного ключа задания, что защищает целостность данных и предотвращает превышение лимитов частоты. Кроме того, он отслеживает и предоставляет актуальные состояния прогресса (такие как «работает», «загружается», «завершается»), которые можно опрашивать для мониторинга статуса задания в реальном времени.

Целевые случаи использования:

Предотвращение параллельных запусков, инициируемых вебхуками, cron-задачами или вложенными вызовами рабочих процессов
Реализация легковесной блокировки без полных систем очередей
Отслеживание прогресса длительных задач с обновлениями статуса в реальном времени
Защита от превышения лимита частоты для внешних API-вызовов
Фильтрация спама от всплесков обратных вызовов (например, боты Telegram)
Обеспечение отсутствия наложения задач по обслуживанию

Логические блоки:

1.1 Прием входных данных: Получает входные данные триггера (action, key, value, timeout) из других рабочих процессов.
1.2 Маршрутизация действий: Использует узел Switch для маршрутизации потока в зависимости от типа действия (get, set, unset).
1.3 Взаимодействие с Redis: Выполняет операции Redis (получение, установка с TTL, удаление) по ключам с именем process_status_<key>.
1.4 Проверка блокировки и управление потоком: Использует узлы If для определения, существует ли блокировка, и нужно ли продолжать, остановиться или выдать ошибку.
1.5 Симуляция долгих задач и обновления прогресса: Симулирует долгие задачи с узлами Wait, обновляя ключи Redis для отражения состояний прогресса.
1.6 Завершение рабочего процесса: Удаляет блокировку после завершения задания, позволяя выполнять будущие запуски.
1.7 Проверка статуса: Обеспечивает путь для запроса текущего прогресса и соответствующей обработки выходных состояний.