Merge pull request #2228 from aswanthabam/perf-register

feat :added celery for running mail

Dockerfile

@@ -7,5 +7,5 @@ RUN apt-get update -y  && apt-get install -y default-libmysqlclient-dev python-d
 COPY ./requirements.txt .
 RUN pip install -r requirements.txt
 COPY . .
-EXPOSE 8000
-ENTRYPOINT sh entrypoint.sh
+# EXPOSE 8000
+# ENTRYPOINT sh entrypoint.sh

api/register/register_views.py

@@ -12,6 +12,7 @@
 from .register_helper import get_auth_token
 from django.views.decorators.cache import cache_page
 from django.core.cache import cache
+from mu_celery.task import send_email
 
 
 class UserRegisterValidateAPI(APIView):
@@ -119,10 +120,10 @@ def post(self, request):
 
         response_data = serializers.UserDetailSerializer(user, many=False).data
 
-        send_template_mail(
-            context=response_data,
-            subject="YOUR TICKET TO µFAM IS HERE!",
-            address=["user_registration.html"],
+        send_email.delay(
+            response_data,
+            "YOUR TICKET TO µFAM IS HERE!",
+            ["user_registration.html"],
         )
 
         res_data["data"] = response_data

docker-compose.yml

@@ -1,4 +1,4 @@
-version: '3'
+version: "3"
 services:
   mulearnbackend:
     build:
@@ -15,3 +15,18 @@ services:
       - /var/www/mulearnbackend/media:/app/media
     env_file:
       - .env
+    entrypoint: sh entrypoint.sh
+  celery:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    container_name: celery
+    image: mulearnbackend-celery
+    restart: always
+    volumes:
+      - /var/log/mulearnbackend:/var/log/mulearnbackend
+      - /var/www/mulearnbackend/assets:/app/assets
+      - /var/www/mulearnbackend/media:/app/media
+    env_file:
+      - .env
+    command: celery -A mulearnbackend.celery worker -l info

mu_celery/task.py

@@ -0,0 +1,7 @@
+from celery import shared_task
+from utils.utils import send_template_mail
+
+
+@shared_task
+def send_email(context: dict, subject: str, address: list[str], attachment: str = None):
+    return send_template_mail(context, subject, address, attachment)

mulearnbackend/__init__.py

@@ -0,0 +1,5 @@
+# This will make sure the app is always imported when
+# Django starts so that shared_task will use this app.
+from .celery import app as celery_app
+
+__all__ = ("celery_app",)

mulearnbackend/celery.py

@@ -0,0 +1,17 @@
+import os
+
+from celery import Celery
+
+# Set the default Django settings module for the 'celery' program.
+os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mulearnbackend.settings")
+
+app = Celery("mulearnbackend")
+
+# Using a string here means the worker doesn't have to serialize
+# the configuration object to child processes.
+# - namespace='CELERY' means all celery-related configuration keys
+#   should have a `CELERY_` prefix.
+app.config_from_object("django.conf:settings", namespace="CELERY")
+
+# Load task modules from all registered Django apps.
+app.autodiscover_tasks()

mulearnbackend/settings.py

@@ -134,6 +134,9 @@
     },
 }
 
+CELERY_BROKER_URL = f"redis://{REDIS_HOST}:{REDIS_PORT}/2"
+CELERY_RESULT_BACKEND = f"redis://{REDIS_HOST}:{REDIS_PORT}/2"
+
 # Use the Redis cache as the default cache
 CACHES["default"] = CACHES["redis"]
 

requirements.txt

@@ -21,4 +21,5 @@ qrcode==7.4.2
 pymysql==1.0.2
 razorpay==1.4.2
 reportlab==4.2.0
-django_redis==5.4.0
+django_redis==5.4.0
+celery==5.4.0