Повторите задачи с сельдереем (Celery, Django и RabbitMQ)

Question

Можете ли вы сказать мне, что происходит, когда в сельдерее вы говорите задачу повторить? Будет ли он повторен в том же рабочем потоке, или он будет возвращен посреднику, который может отправить его в другое место?

Что будет с заданиями на повтор, если работник или диспетчер внезапно остановятся? Если задачи могут быть потеряны, есть ли какой-то подход, чтобы избежать этого? Может быть, сохранить каждую задачу в базе данных и повторить их, если в течение некоторого времени ничего не получено?

Или у диспетчера может быть свое постоянное хранилище? А что тогда, если рабочий поток аварийно завершает работу, получая задачу или выполняя ее?

Answer 1

Можете ли вы сказать мне, что происходит, когда в сельдерее вы предлагаете задачу повторить?Повторится ли он в том же рабочем потоке или будет возвращен посреднику, который может отправить его в другое место?

Да, задание вернется к посреднику (например, Rabbit MQ) с другим предполагаемым временем выполнения

Что произойдет с повторными заданиями, если работник или диспетчер внезапно остановятся?Если задачи могут быть потеряны, есть ли какой-то подход, чтобы избежать этого?Может быть, сохранить каждую задачу в базе данных и повторить их, если в течение некоторого времени ничего не получено?Или может быть диспетчер имеет свое постоянное хранилище?А как насчет того, если рабочий поток аварийно завершает работу, получая или выполняя задачу?

Здесь полный ответ Повторить потерянные или неудачные задачи (Celery, Django и RabbitMQ)