Для чего нужен Celery

Celery — это распределённая очередь задач (distributed task queue), которая позволяет выполнять фоновые или отложенные задачи асинхронно. Основные сценарии использования:

• Фоновые задачи (например, отправка email, обработка файлов)
• Периодические задачи (через Celery Beat)
• Распределённая обработка (параллельное выполнение на нескольких worker'ах)
• Долгие операции (чтобы не блокировать основной поток приложения)

Пример:

from celery import Celery

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

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

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

Ключевые компоненты:

• Broker (Redis, RabbitMQ) — хранит задачи.
• Worker — выполняет задачи.
• Result Backend (опционально) — сохраняет результаты.

Celery особенно полезен в веб-приложениях, где важно не блокировать HTTP-запросы долгими операциями.