كيف تشغل المهام الخلفية باستخدام Celery؟

Question

Accepted Answer

**Celery** هي الأداة القياسية لتشغيل **المهام الخلفية والمهام المجدولة** في Django — العمل الذي لا يجب أن يعيق طلب HTTP (إرسال رسائل بريد إلكترونية، معالجة الملفات، استدعاء واجهات برمجية بطيئة) أو الذي يعمل وفقًا لجدول زمني. يتم وضع المهام في قائمة انتظار ومعالجتها بشكل غير متزامن بواسطة عمليات **worker** منفصلة.

## المشكلة التي يحلها Celery

```python
# ❌ doing slow work inline blocks the response — the user waits, risks timeouts
def register(request):
    user = create_user(request.POST)
    send_welcome_email(user)           # slow — the user waits for the email to send
    generate_report(user)               # even slower
    return redirect("home")             # finally responds after all that
```

إجراء العمل البطيء بشكل مباشر يجعل المستخدمين ينتظرون ويخاطر بانتهاء انتظار الطلب. يقوم Celery بتفريغ هذا العمل إلى عمال خلفيين بحيث يعود الطلب على الفور.

## تعريف واستدعاء مهمة Celery

```python
# tasks.py — define a task
from celery import shared_task

@shared_task
def send_welcome_email(user_id):
    user = User.objects.get(id=user_id)
    send_email(user.email, "Welcome!")    # runs in a WORKER, not the web process

# in a view — QUEUE the task instead of running it inline
def register(request):
    user = create_user(request.POST)
    send_welcome_email.delay(user.id)     # .delay() queues it → returns IMMEDIATELY
    return redirect("home")                # user gets a fast response
```

مصرف الديكوريتور `@shared_task` يعرّف مهمة؛ `.delay()` (أو `.apply_async()`) يضعها في قائمة انتظار ليقوم عامل بمعالجتها بشكل غير متزامن — لا تنتظر العرض.

## البنية المعمارية

```text
Django (web) --.delay()--> BROKER (Redis/RabbitMQ) --> CELERY WORKER (processes the task)
                              (the message queue)         (separate process/machine)
```

```text
Components:
  ✓ Broker (Redis or RabbitMQ) — holds the queue of pending tasks
  ✓ Celery worker(s) — separate processes that pull and execute tasks
  ✓ Result backend (optional) — stores task results/status
Run workers separately: `celery -A myproject worker`
```

## المهام المجدولة / الدورية (Celery Beat)

```python
# run tasks on a schedule (like cron) via Celery Beat
CELERY_BEAT_SCHEDULE = {
    "daily-report": {
        "task": "myapp.tasks.generate_daily_report",
        "schedule": crontab(hour=0, minute=0),     # every midnight
    },
}
```

## ميزات الموثوقية

```python
@shared_task(bind=True, max_retries=3, default_retry_delay=60)
def sync_data(self):
    try:
        do_sync()
    except Exception as exc:
        raise self.retry(exc=exc)             # automatic retries on failure
```

```text
✓ Retries with backoff (resilience against transient failures)
✓ Task persistence (queued tasks survive restarts via the broker)
✓ Scheduling (Celery Beat — periodic/cron-like tasks)
✓ Rate limiting, concurrency control, task routing/priorities
✓ Workers scale independently of web servers
```

## لماذا الأمر مهم

معالجة المهام الخلفية باستخدام Celery هي معرفة ضرورية لبناء تطبيقات Django سريعة الاستجابة وقابلة للتوسع، لأن العديد من الاحتياجات الحقيقية تتطلب عملاً لا يجب أن يحدث بشكل مباشر أثناء الطلب.

فهمه مهم لأن المشكلة الأساسية — تفريغ العمل البطيء أو المؤجل (إرسال رسائل بريد إلكترونية، معالجة الصور/الملفات، إنشاء التقارير، استدعاء واجهات برمجية خارجية بطيئة، مزامنة البيانات) من دورة الطلب-الاستجابة — منتشرة في التطبيقات الإنتاجية.

إجراء هذا العمل بشكل مباشر يجعل المستخدمين ينتظرون، ويخاطر بانتهاء انتظار الطلب، ويفقد العمل إذا فشل، بينما **Celery** يسمح لك بالرد على المستخدم على الفور بينما يقوم **عمال** منفصلون بمعالجة العمل بشكل غير متزامن وموثوق.

بعيدًا عن التفريغ غير المتزامن البسيط، توفر Celery قدرات إنتاجية حرجة: **المهام المجدولة/الدورية** (عبر Celery Beat، الذي يحل محل cron للجدولة على مستوى التطبيق — التقارير اليومية، وظائف التنظيف، المزامنات المتكررة)، **إعادة المحاولة التلقائية مع التراجع** (المرونة ضد الأخطاء العابرة)، **استمرارية المهام** (المهام المقائمة تبقى حية عبر الوسيط مثل Redis/RabbitMQ، حتى لا يتم فقدان العمل)، و **التوسع المستقل** للعمال عن خوادم الويب.

فهم معمارية Celery (الوسيط مثل Redis/RabbitMQ الذي يحتفظ بالقائمة، والعمال يعالجون المهام، واجهة النتائج)، وكيفية تعريف وقائمة المهام (`@shared_task`, `.delay()`)، وجدولة العمل الدوري، وتكوين ميزات الموثوقية هو معرفة قيمة على مستوى أعلى لبناء أنظمة Django الإنتاجية التي تتعامل مع العمل الثقيل أو المؤجل بأناقة.

نظرًا لأن معالجة الخلفية هي متطلب شائع ومهم للتطبيقات سريعة الاستجابة والقوية — و Celery هي الحل الفعلي القياسي في نظام بيئة Django — فإن إتقانها هو مهارة عملية وذات صلة بشكل متكرر تعكس القدرة على بنية تطبيقات Django الحقيقية بما يتجاوز المعالجة المتزامنة البسيطة للطلبات.