Какие проблемы решал в Celery

Celery решает несколько ключевых проблем в асинхронной обработке задач:

1. Фоновые и длительные операции – позволяет выносить тяжелые задачи (отправка email, обработка данных) из основного потока приложения.
2. Распределённая обработка – масштабируется на несколько worker’ов и серверов.
3. Планирование задач – поддерживает отложенное выполнение (ETA) и периодические задачи (beat).
4. Надёжность – сохраняет задачи в брокере (RabbitMQ, Redis) и перезапускает их при сбоях.

Пример:

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}")
    return True

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

Популярные альтернативы: RQ (проще), Dramatiq (быстрее для некоторых сценариев).