Доля Celery очереди с функциями Django и запуск работников при запуске
У меня есть проект Django и 2 работника Celery, я хочу запустить работника 1 при запуске django и обновить хранилище некоторых vars в очереди, другой рабочий должен быть вызван всякий раз, когда я захочу, и использую vars, хранящиеся в очереди, Я также хочу иметь возможность читать очереди очередей из других функций, не связанных с сельдереем. Моя проблема в том, что я не знаю, где я должен позвонить первому работнику в Django, а также как определить глобальную очередь. Для вызова рабочего я попробовал urls.py, но, похоже, он называет его несколько раз.
1 ответ
Я настоятельно рекомендую вам проверить начало работы с документами django и celery. Кажется, ваш подход не уместен, или вы не имеете достаточного знания о маханизме очереди задач сельдерея.
-
1Я прочитал документы. Поскольку я новичок в джанго, мне было трудно понять это полностью. Я много знаю о многопоточности. В многопоточности 2 поток может связываться через очередь. Может django общаться с сельдереем. Я знаю, как получить состояние сельдерея, но вы также можете отправить переменную в задание в цикле? – Pourya 13 August 2018 в 18:21
-
2вы должны использовать задачу сельдерея, чтобы украсить функции просмотра django. и записывать задачи сельдерея в файл tasks.py внутри папки вашего приложения. сельдерей использует многопроцессорный модуль и обрабатывает сам вопрос. вы должны более подробно проверить задачи сельдерея. – auvipy 13 August 2018 в 20:14