دمج RabbitMQ مع Django لإرسال الإشعارات بشكل غير متزامن

دمج RabbitMQ مع Django لإرسال الإشعارات بشكل غير متزامن

إذا كنت تبني مشروع Django فيه إرسال إشعارات (Emails، SMS، Push Notifications، إشعارات داخل النظام)، فغالبًا ستواجه مشكلة في الأداء عند تنفيذ هذه المهام مباشرة داخل request/response. هنا يأتي دور RabbitMQ كـ Message Broker يساعدك على تنفيذ إرسال الإشعار في الخلفية بشكل غير متزامن وتحسين استجابة التطبيق.

في هذا المقال سنشرح خطوة بخطوة كيفية دمج RabbitMQ مع Django لبناء نظام django rabbitmq notifications احترافي، بداية من الفكرة، ثم الإعداد، ثم كتابة الكود، مع بعض أفضل الممارسات.

لماذا نحتاج RabbitMQ مع Django لإرسال الإشعارات؟

بشكل افتراضي، عند تنفيذ أي عملية ثقيلة داخل Django (مثل إرسال بريد إلكتروني أو إشعار Push أو اتصال خارجي)، فإنها تنفذ داخل نفس طلب HTTP. هذا يؤدي إلى:

  • بطء في استجابة الصفحة للمستخدم.
  • احتمال حدوث Timeout في الطلب.
  • ضغط كبير على موارد السيرفر.

بدلاً من ذلك، نريد:

  • استقبال الطلب من المستخدم سريعًا.
  • تخزين مهمة الإشعار في Queue في RabbitMQ.
  • معالجة الإشعار في الخلفية بواسطة Worker.

بهذا الشكل نحصل على:

  • تجربة مستخدم أفضل (response سريع).
  • قابلية أعلى للتوسع (يمكن زيادة عدد الـ Workers).
  • عزل منطق الإشعارات عن منطق الـ Views.

إذا كنت جديدًا على RabbitMQ وWork Queues، يمكنك مراجعة مقالنا: Work Queues في RabbitMQ: تنفيذ المهام الثقيلة في الخلفية.

المفهوم العام لتكامل Django مع RabbitMQ

فكرة الربط بين Django و RabbitMQ في حالة الإشعارات يمكن تلخيصها في 3 خطوات:

  1. المنتج (Producer): جزء من تطبيق Django يرسل رسالة (Message) إلى RabbitMQ عند حدوث حدث معيّن (مثل تسجيل مستخدم جديد).
  2. الوسيط (Broker): RabbitMQ يستقبل الرسالة ويضعها في Queue معيّن (مثل notifications_queue).
  3. المستهلك (Consumer / Worker): سكربت أو خدمة Python تعمل في الخلفية تستهلك الرسائل من الـ Queue وترسل الإشعارات فعليًا.

بهذا الشكل، يقوم Django فقط بـ "جدولة" الإشعار، بينما وظيفة التنفيذ الحقيقية تتم في الخلفية.

المتطلبات الأساسية

قبل البدء، تأكد من توفر الآتي:

  • مشروع Django (نسخة حديثة مثل 3.2 أو 4.x).
  • تثبيت وتشغيل RabbitMQ (محليًا أو على سيرفر).
  • بايثون 3.8+.

للتعامل مع الـ Background Tasks في Django بشكل عام، يمكنك الاطلاع أيضًا على: التعامل مع Background Tasks في Django وFastAPI.

تنصيب الأدوات اللازمة في Django

1. تثبيت مكتبة pika للتعامل مع RabbitMQ

نستخدم غالبًا مكتبة pika للتعامل مع RabbitMQ في بايثون: 

pip install pika

يمكنك استخدام مكتبات أخرى أو حتى أدوات جاهزة مثل Celery، لكن في هذا المقال سنبقى في مستوى أقرب لـ “Raw RabbitMQ” لفهم الفكرة الأساسية.

2. إعداد متغيرات الاتصال بـ RabbitMQ في settings.py

في ملف settings.py أضف إعدادات الاتصال بـ RabbitMQ (يفضل استخدامها من متغيرات البيئة): 

# settings.py
RABBITMQ_HOST = "localhost"
RABBITMQ_PORT = 5672
RABBITMQ_USER = "guest"
RABBITMQ_PASSWORD = "guest"
RABBITMQ_NOTIFICATIONS_QUEUE = "notifications_queue"

يمكنك لاحقًا فصل هذه القيم في ملف إعدادات مستقل أو استخدام بيئات مختلفة (development، production) كما شرحت سابقًا في: التحكم بالإصدارات في Django: إدارة migrations بشكل صحيح (نفس الفكرة في تنظيم الإعدادات).

إنشاء طبقة الاتصال بـ RabbitMQ في Django

من الجيد عدم كتابة كود الاتصال بـ RabbitMQ داخل الـ View مباشرة. الأفضل إنشاء ملف Helper أو Service لإعادة استخدامه لاحقًا.

1. إنشاء ملف producer في تطبيق notifications

لنفرض أن لدينا تطبيق داخل المشروع اسمه notifications. سننشئ ملف rabbitmq_producer.py بداخله: 

# notifications/rabbitmq_producer.py
import json
import pika
from django.conf import settings


def get_rabbitmq_connection():
    credentials = pika.PlainCredentials(
        settings.RABBITMQ_USER,
        settings.RABBITMQ_PASSWORD
    )
    parameters = pika.ConnectionParameters(
        host=settings.RABBITMQ_HOST,
        port=settings.RABBITMQ_PORT,
        credentials=credentials
    )
    return pika.BlockingConnection(parameters)


def publish_notification(message: dict):
    """
    إرسال رسالة إشعار إلى Queue في RabbitMQ.
    message يجب أن يكون dict قابل للتحويل إلى JSON.
    """
    connection = get_rabbitmq_connection()
    channel = connection.channel()

    # تأكد من وجود الـ Queue (idempotent)
    channel.queue_declare(queue=settings.RABBITMQ_NOTIFICATIONS_QUEUE, durable=True)

    body = json.dumps(message)

    channel.basic_publish(
        exchange="",
        routing_key=settings.RABBITMQ_NOTIFICATIONS_QUEUE,
        body=body.encode("utf-8"),
        properties=pika.BasicProperties(
            delivery_mode=2  # جعل الرسالة persistent
        ),
    )

    connection.close()

بهذا الشكل يمكن لأي جزء داخل Django استدعاء publish_notification لجدولة إرسال إشعار في الخلفية.

دمج RabbitMQ داخل Django: مثال عملي على إرسال إشعار ترحيبي

1. سيناريو: تسجيل مستخدم جديد

عند تسجيل مستخدم جديد، نريد:

  • إعادة response مباشرة للمستخدم بأن التسجيل نجح.
  • إرسال بريد إلكتروني ترحيبي في الخلفية.

نفترض أن لدينا View لتسجيل المستخدم: 

# users/views.py
from django.http import JsonResponse
from django.views.decorators.http import require_POST
from django.contrib.auth.models import User

from notifications.rabbitmq_producer import publish_notification


@require_POST
def register(request):
    # قراءة البيانات من request.POST أو request.body
    email = request.POST.get("email")
    username = request.POST.get("username")
    password = request.POST.get("password")

    user = User.objects.create_user(
        username=username,
        email=email,
        password=password
    )

    # إرسال رسالة إشعار إلى RabbitMQ
    notification_message = {
        "type": "WELCOME_EMAIL",
        "to_email": email,
        "username": username,
    }
    publish_notification(notification_message)

    # إعادة response سريع للمستخدم
    return JsonResponse({"status": "success", "message": "تم إنشاء الحساب بنجاح"})

لاحظ أن إرسال الإيميل الفعلي لم يتم هنا. فقط أرسلنا رسالة إلى الـ Queue. وظيفة الإرسال يقوم بها Worker في الخلفية.

إنشاء Worker (Consumer) لاستهلاك رسائل الإشعارات

الآن نحتاج سكربت Python يعمل خارج Django (أو مرتبط بمشروع Django) يستهلك رسائل notifications_queue ويقوم فعليًا بإرسال الإشعار.

1. إنشاء ملف worker داخل تطبيق notifications

لننشئ ملف اسمه notifications_worker.py في جذر المشروع أو داخل التطبيق: 

# notifications/notifications_worker.py
import json
import os
import django
import pika

# إعداد Django إذا كان هذا الملف خارج manage.py
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "project_name.settings")
django.setup()

from django.conf import settings
from django.core.mail import send_mail


def process_notification(message: dict):
    """
    دالة تُنفّذ بناءً على نوع الإشعار.
    """
    notification_type = message.get("type")

    if notification_type == "WELCOME_EMAIL":
        to_email = message.get("to_email")
        username = message.get("username")

        subject = "مرحبًا بك في موقعنا"
        body = f"مرحبًا {username}، شكراً لتسجيلك في موقعنا."
        send_mail(
            subject,
            body,
            settings.DEFAULT_FROM_EMAIL,
            [to_email],
            fail_silently=False,
        )
    else:
        # يمكن تسجيل أنواع أخرى أو تجاهلها
        print(f"Unknown notification type: {notification_type}")


def main():
    credentials = pika.PlainCredentials(
        settings.RABBITMQ_USER,
        settings.RABBITMQ_PASSWORD
    )
    parameters = pika.ConnectionParameters(
        host=settings.RABBITMQ_HOST,
        port=settings.RABBITMQ_PORT,
        credentials=credentials
    )
    connection = pika.BlockingConnection(parameters)
    channel = connection.channel()

    channel.queue_declare(queue=settings.RABBITMQ_NOTIFICATIONS_QUEUE, durable=True)
    print(" [*] Waiting for messages in notifications_queue. To exit press CTRL+C")

    def callback(ch, method, properties, body):
        try:
            message = json.loads(body.decode("utf-8"))
            process_notification(message)
            # تأكيد استهلاك الرسالة
            ch.basic_ack(delivery_tag=method.delivery_tag)
        except Exception as e:
            # في حالة حدوث خطأ يمكن تسجيله أو إعادة إرسال الرسالة
            print(f"Error processing message: {e}")
            # عدم إرسال ack يترك الرسالة في الـ Queue لإعادة المحاولة أو التعامل اليدوي

    # التأكد من عدم إرسال أكثر من رسالة غير معالجة لنفس الـ Worker
    channel.basic_qos(prefetch_count=1)
    channel.basic_consume(
        queue=settings.RABBITMQ_NOTIFICATIONS_QUEUE,
        on_message_callback=callback,
    )

    channel.start_consuming()


if __name__ == "__main__":
    main()

يمكن تشغيل هذا الـ Worker عن طريق: 

python -m notifications.notifications_worker

أو تعديل المسار حسب هيكلة مشروعك.

تصميم نظام django rabbitmq notifications بشكل قابل للتوسع

ما سبق هو أبسط شكل للنظام. لكن عند الانتقال للإنتاج نحتاج إلى التفكير في:

  • أنواع متعددة من الإشعارات: Email، SMS، Push، In-App.
  • Queues متعددة: كل نوع إشعار في Queue خاص (مثلاً: email_notifications، sms_notifications).
  • Workers متعدّدون: تشغيل أكثر من Worker لخدمة نفس الـ Queue أو Queues مختلفة.

يمكنك إضافة حقل channel في الرسالة لتحديد نوع القناة: 

{
  "type": "ORDER_STATUS",
  "channel": "EMAIL",
  "to_email": "[email protected]",
  "order_id": 123
}

ثم في دالة process_notification تقوم بالتفريع حسب channel و type.

أفضل الممارسات عند دمج RabbitMQ مع Django

1. عدم خلط منطق RabbitMQ في كل View

حاول دائمًا أن:

  • تضع منطق إرسال الرسائل إلى RabbitMQ في Service Layer أو Helper موحد مثل rabbitmq_producer.py.
  • تستخدم Functions مثل send_welcome_email_notification(user) تستدعي داخليًا publish_notification.

2. التعامل مع الأخطاء بشكل واضح

يجب التفكير في:

  • ماذا لو RabbitMQ غير متوفر؟ هل تفشل عملية التسجيل بالكامل أم تسجل وتفشل الإشعار فقط؟
  • هل نحتاج إلى Retry Logic في جانب الـ Worker؟

في كثير من الأحيان، من الأفضل:

  • إنشاء المستخدم بنجاح.
  • تسجيل فشل إرسال الإشعار في الـ Logs أو قاعدة البيانات.
  • إعادة المحاولة لاحقًا من خلال Worker آخر أو Cron Job.

3. استخدام Environment Variables في الإعدادات

لا تقم بتثبيت قيم اتصال RabbitMQ في الكود مباشرة. استخدم متغيرات البيئة (ENV) خاصة في بيئة الإنتاج، وتأكد من وجود إعدادات مختلفة للتطوير والإنتاج.

4. مراقبة الـ Queues والـ Workers

RabbitMQ يوفر Management UI (غالبًا على المنفذ 15672) يمكنك استخدامه لمراقبة:

  • عدد الرسائل في كل Queue.
  • عدد المستهلكين (Consumers).
  • حالة الاتصال.

بهذا تتأكد أن نظام الإشعارات يعمل بشكل مستمر ولا تتراكم الرسائل بشكل غير طبيعي.

مقارنة سريعة مع حلول أخرى (مثل Celery)

في مشاريع Django كثيرة، يتم استخدام Celery مع RabbitMQ أو Redis كأساس للـ Task Queue. Celery يوفر:

  • تعريف Tasks بشكل أسهل.
  • آليات Retry مدمجة.
  • جدولة دورية (Periodic Tasks).

لكن الفائدة من المثال في هذا المقال هو:

  • فهم المستوى المنخفض للتكامل مع RabbitMQ.
  • إمكانية تصميم Notification Service مخصص تمامًا لاحتياجاتك.

وإذا أردت التوسع في تصميم Service كامل للإشعارات باستخدام RabbitMQ وMicroservices، راجع: تصميم Notification Service باستخدام RabbitMQ في Microservices.

نصائح إضافية لتحسين الأداء والأمان

  • فصل الإعدادات الحساسة: لا تحفظ بيانات المستخدم وكلمات المرور داخل الرسائل، استخدم IDs فقط واجلب البيانات من قاعدة البيانات داخل Worker.
  • تقليل حجم الرسائل: الرسائل يجب أن تكون خفيفة، مثلاً إرسال user_id بدلاً من إرسال كل بيانات المستخدم.
  • استخدام Routing Keys وExchanges متقدمة: في الأنظمة الكبيرة يمكنك استخدام Topic Exchanges لتوجيه أنواع إشعارات مختلفة إلى Queues مختلفة.
  • تنظيم الكود داخل Django: استخدم بنية واضحة للتطبيق المسؤول عن الإشعارات، واجعل كل نوع إشعار في ملف أو Class منفصل.

خلاصة: بناء نظام django rabbitmq notifications احترافي

دمج Django مع RabbitMQ لإرسال الإشعارات بشكل غير متزامن يعطيك:

  • سرعة أكبر في استجابة الـ API أو الموقع.
  • إمكانية التعامل مع عدد كبير من الإشعارات بدون الضغط على التطبيق الأساسي.
  • هيكلية نظيفة تفصل بين منطق الـ Web ومنطق الـ Background Jobs.

الخطوات الأساسية كانت:

  1. إعداد اتصال RabbitMQ في settings.py.
  2. إنشاء Producer في Django لإرسال رسائل الإشعارات.
  3. استخدام هذا الـ Producer في Views أو Signals عند حدوث أحداث مهمة (تسجيل مستخدم، تغيير حالة طلب، ...).
  4. بناء Worker (Consumer) يستهلك الرسائل ويرسل الإشعارات فعليًا.
  5. تطوير التصميم ليشمل أنواع وقنوات إشعار متعددة، مع مراقبة وتحسين للأداء.

بهذا تكون قد وضعت الأساس لبناء نظام django rabbitmq notifications فعّال وقابل للتوسع، يمكن توسيعه لاحقًا ليدعم قنوات إشعار متعددة، وإدارة Retry، وتحليل أداء الإشعارات، وربطه مع خدمات أخرى في بنية Microservices أو نظام واحد متماسك.

حول المحتوى:

شرح ربط Django مع RabbitMQ لإرسال الإشعارات في الخلفية وتحسين الأداء.

هل كان هذا مفيدًا لك؟

أضف تعليقك