Question Django + Celery

Hello ! Est-ce quelqu'un aurait déjà intégré Django + Celery avec Azure ou AWS ? J'ai des questions sur la configuration de Redis

Je bosse actuellement avec un freelance et on est en train de configurer deux environnements pour réaliser les déploiements : un environnement de test et un environnement de production. Ca me fait trois environnements au total : local, test, prod.

Pour les tests à effectuer, ma question est : est-il possible d'inclure les tâches Celery dans les migrations Django au même titre que les modèles ? Ca faciliterait le déploiement une fois les tests réalisés

Oui, il est possible d'inclure des tâches Celery dans les migrations Django. Vous pouvez utiliser la bibliothèque django-celery pour vous aider à configurer et à gérer vos tâches Celery. Vous pouvez également utiliser la bibliothèque django-redis pour configurer et gérer votre instance Redis. Ces bibliothèques vous aideront à configurer et à gérer vos tâches Celery et votre instance Redis sur Azure ou AWS.

Pour commencer, tu dois installer et configurer la bibliothèque Celery. Tu peux le faire en ajoutant l'application Celery à ton fichier de configuration Django et en définissant les variables d'environnement nécessaires. Voici un exemple de code pour le faire :

# settings.py

INSTALLED_APPS = [
    ...
    'django_celery_results',
    'django_celery_beat',
    'celery',
]

BROKER_URL = 'amqp://localhost'

CELERY_RESULT_BACKEND = 'django-db'

Ensuite, tu dois définir une tâche Celery dans un fichier séparé. Voici un exemple :

# tasks.py

from celery import shared_task

@shared_task
def my_task():
    # Do something here
    pass

Enfin, tu dois inclure la tâche Celery dans les migrations Django. Tu peux le faire en ajoutant une déclaration de migration à ton fichier de migration. Voici un exemple de code pour le faire :

# migrations.py

from django.db import migrations
from celery.contrib.migrate import migrate_tasks

def add_celery_tasks(apps, schema_editor):
    migrate_tasks(apps, schema_editor, 'tasks')

class Migration(migrations.Migration):
    dependencies = [
        ('myapp', '0001_initial'),
    ]
    operations = [
        migrations.RunPython(add_celery_tasks),
    ]