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

Celery — это распределенная очередь задач для Python, часто используемая для асинхронной обработки фоновых задач, например, отправки email, обработки данных или выполнения тяжелых вычислений.

Пример:

1. Установка:

pip install celery redis

2. Создаем файл tasks.py:

from celery import Celery

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

@app.task
def add(x, y):
return x + y

3. Запускаем Celery worker:
```bash
celery -A tasks worker --loglevel=info

4. Запускаем задачу из другого скрипта или консоли:

from tasks import add

result = add.delay(4, 6)  # Асинхронный вызов
print(result.get())       # Получаем результат (блокирующий вызов)

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

• broker (например, Redis/RabbitMQ) хранит задачи в очереди.
• @app.task декорирует функцию как Celery-задачу.
• delay() ставит задачу в очередь.
• get() ожидает результат (если нужно).