Вот несколько методов, которые вы можете использовать с Django Celery 5.0:
-
Создание задач. Определите задачи с помощью декоратора
@task
или создав подклассcelery.Task
. Это позволяет вам определять функции или классы, которые могут выполняться асинхронно. -
Вызов задачи. Вызов задач с помощью методов
delay()
илиapply_async()
. Эти методы ставят задачу для выполнения работником Celery. -
Планирование задач: планируйте запуск задач в определенное время, используя параметры планирования Celery. Вы можете использовать такие методы, как
apply_async()
с параметромeta
, или использовать Celerybeat, который является компонентом Celery для периодического планирования задач. -
Обработка результатов задачи: получение результатов задачи с помощью объекта
AsyncResult
, возвращаемого функциейapply_async()
. Вы можете проверить статус задачи, получить результат или обработать любые исключения, которые могли возникнуть. -
Повторение задачи. Настройте задачи на повторную попытку в случае сбоя с помощью декоратора
retry()
или установив атрибутretry
задачи. Это позволяет вам определить количество повторений, интервалы повторов и пользовательские условия повтора. -
Связывание задач: связывайте задачи вместе с помощью оператора
|
или методаchain()
. Это позволяет создавать сложные рабочие процессы, в которых задачи выполняются последовательно или параллельно. -
Мониторинг задач: отслеживайте выполнение задач с помощью таких инструментов, как Flower. Flower предоставляет веб-интерфейс мониторинга, с помощью которого вы можете просматривать ход выполнения задач, отслеживать активность работников и проверять детали задач.
-
Отзыв задачи: отмените или прекратите выполнение выполняемой задачи с помощью метода
revoke()
. Это позволяет при необходимости остановить выполнение задачи. -
Тайм-ауты задач. Определите тайм-ауты для задач с помощью параметров
soft_time_limit
иtime_limit
. Эти параметры ограничивают время выполнения задачи и позволяют корректно обрабатывать тайм-ауты.