Постоянство активных задач сельдерея

Question

Если при выполнении какого-либо задания происходит сбой сельдерея, это задание теряется после перезапуска сельдерея.Задачи, которые в очереди в момент сбоя, будут нормально восстановлены в RabbitMQ.Но как сделать активные задачи постоянными?

Answer 1

Сельдерей по умолчанию настроен на task_acks_late=False.[1] Это означает, что задание подтверждено, как только работник получает его из очереди.И если задача не выполняется, очередь не может узнать об этом.

Установите task_acks_late на True, и задача будет подтверждена после того, как было обработано.Когда задача не выполняется, она ставится в очередь.[2] Но будьте осторожны, ваши задачи должны быть идемпотентными .[3]

• [1] http://docs.celeryproject.org/en/latest/userguide/configuration.html#std:setting-task_acks_late
• [2] http://docs.celeryproject.org/en/latest/faq.html#faq-acks-late-vs-retry
• [3] https://en.wikipedia.org/wiki/Idempotence