Как Celery взаимодействует с Django

Celery интегрируется с Django через настройки в settings.py. Основные шаги:

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

pip install celery redis  # redis как брокер сообщений

2. В settings.py добавляем конфигурацию:

CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

3. Создаем файл celery.py в папке проекта (рядом с settings.py):

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')
app = Celery('project')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

4. В `__init__.py` проекта добавляем:
```python
from .celery import app as celery_app
__all__ = ['celery_app']

5. Создаем задачи в tasks.py любого приложения:

from celery import shared_task

@shared_task
def send_email_task():
    # логика отправки email
    return "Email sent!"

Запуск Celery worker:

celery -A project worker -l info

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

• Использует брокеры (Redis, RabbitMQ) для очередей задач
• Интегрируется с Django ORM
• Поддерживает отложенное выполнение (task.apply_async(countdown=3600))
• Работает с Django-моделями в задачах