Что хотят услышать интервьюеры:

Важно услышать, что Celery использовался не “для галочки”, а для реальной разгрузки синхронного приложения. Обычно ожидают понимания, какие задачи выносились в фон, как настраивались брокер и воркеры, и какие проблемы пришлось решать. Хорошо, если есть опыт с ретраями, идемпотентностью и мониторингом выполнения задач.

Определение:

Celery — это библиотека для асинхронного выполнения фоновых задач в Python. Она позволяет отправлять долгие или ресурсоёмкие операции в очередь, чтобы основной поток приложения быстро отвечал пользователю. Для работы обычно используют брокер сообщений, например Redis или RabbitMQ, и отдельные worker-процессы, которые забирают и выполняют задачи.

Пример использования:

Типичный кейс — отправка email, генерация отчёта или обработка изображения после ответа пользователю. Например, при регистрации пользователя система сразу создаёт аккаунт, а отправку приветственного письма ставит в очередь.

from celery import Celery

app = Celery(
    "tasks",
    broker="redis://localhost:6379/0",
    backend="redis://localhost:6379/1",
)

@app.task
def send_welcome_email(user_id):
    # Здесь обычно: получить пользователя из БД, сформировать письмо и отправить его
    return f"Email sent to user {user_id}"

# Асинхронный запуск задачи
result = send_welcome_email.delay(42)

Пояснение кода:

Создаётся объект Celery с настройкой брокера и backend.
Декоратор @app.task превращает обычную функцию в celery-задачу.
Вызов .delay(42) не выполняет функцию сразу, а отправляет задачу в очередь.
Worker, запущенный отдельно, забирает задачу из очереди и выполняет её.
Результат можно получить через result, если backend настроен на сохранение ответов.

Если говорить про внедрение на практике, обычно это выглядело так: сначала выделялись медленные операции, затем добавлялся брокер, запускались workers, после чего проверялись ретраи, таймауты и логирование. Отдельно важно было следить, чтобы задача можно было безопасно выполнить повторно, если произошёл сбой.

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

Celery нужен для выноса долгих операций из основного потока приложения.
Для работы требуется брокер сообщений и отдельные worker-процессы.
На практике важно продумывать повторный запуск задач, таймауты и обработку ошибок.
Хороший кандидат обычно упоминает мониторинг очередей и статусы выполнения.
Celery особенно полезен для email-рассылок, отчётов, интеграций и фоновой обработки файлов.

Опыт внедрения и использования Celery для обработки асинхронных задач