Доброе утро! Ответьте, пожалуйста, на несколько вопросов по связке rattibmq +

Question

Доброе утро! Ответьте, пожалуйста, на несколько вопросов по связке rattibmq +

celery, кто разбирается:

1) Если у меня воркеры на разных машинах, то под каждого обязательно класть испольняемый код и, соответственно, при изменении в коде, обновлять его на всех нодах?
2) Как отслеживать таких воркеров - на каждого по flower или как-то по другому?
3) Что происходит с очередью тасков при рестарте rabbitmq?
4) Если какую-то задачу надо выполнить периодически, я запускаю celery-beat, но как можно убедиться, что задача выполнится один раз одним воркером, а не один раз одним воркером на каждой ноде? Очевидный, но неудобный ответ - отдельная очередь, отдельный воркер настроенный определенным образом на одной из нод. Другие варианты есть?
5) Если я кидаю в очередь задачу, которую нужно выполнить через определенное время, то как celery воркер понимает, когда ее нужно взять? Это где-то хранится в самом таске, находящемся в rabbitmq?

#backend #django #programming #python #russian

0

19.08.2020