Что такое Celery

Celery — это распределённая очередь задач (distributed task queue) для Python, которая позволяет асинхронно выполнять фоновые задачи вне основного потока приложения. Используется для обработки долгих операций (например, отправка email, обработка данных, генерация отчётов), чтобы не блокировать основной запрос.

Особенности:

• Работает через брокеры сообщений (RabbitMQ, Redis, Amazon SQS).
• Поддерживает периодические задачи (через Celery Beat).
• Масштабируется на несколько воркеров.

Пример:

from celery import Celery

app = Celery('tasks', broker='redis://localhost:6379/0')

@app.task
def send_email(to, subject, body):
    # Логика отправки email
    print(f"Sending email to {to}")

# Вызов задачи асинхронно
send_email.delay("user@example.com", "Hello", "Test email")

Плюсы:

• Простота интеграции с Django/Flask.
• Поддержка ретраев, приоритетов задач.
• Мониторинг через Flower.

Минусы:

• Требует отдельный брокер и воркеры.
• Сложность отладки распределённых задач.