तपाई कसरी Celery को साथ पृष्ठभूमि कार्यहरू चलाउनुहुन्छ?

Question

Accepted Answer

**Celery** Django मा **पृष्ठभूमि र निर्धारित कार्यहरू** चलाउने मानक उपकरण हो — ऐसा काम जो HTTP अनुरोध (इमेल पठाउने, फाइलहरू प्रसंस्करण गर्ने, ढिलो APIs कल गर्ने) लाई अवरुद्ध नगर्नुपर्छ वा अनुसूचीमा चलिन्छ। कार्यहरू विभिन्न **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 अनुप्रयोग निर्माण गर्नको लागि आवश्यक ज्ञान हो, किनकि बहु वास्तविक-विश्व आवश्यकताहरूलाई ऐसा काम आवश्यक छ जो अनुरोधको समयमा इनलाइन हुनुपर्दैन।

यो समझ महत्त्वपूर्ण छ किनभने मुख्य समस्या — ढिलो वा स्थगित काम (इमेल पठाउने, छविहरू/फाइलहरू प्रसंस्करण गर्ने, रिपोर्टहरू उत्पन्न गर्ने, ढिलो बाह्य APIs कल गर्ने, डेटा सिङ्क गर्ने) अनुरोध-प्रतिक्रिया चक्र बाट स्थानान्तरण गर्ने — उत्पादन अनुप्रयोगहरूमा व्यापक छ।

ऐसा काम इनलाइन गर्नुले प्रयोगकर्ताहरू प्रतीक्षा गर्न बाध्य पारिन्छ, अनुरोध समय सीमा समाप्त हुने जोखिम गर्छ, र काम असफल भएमा यो हराउन्छ, जबकि **Celery** ले तपाईलाई तुरन्त प्रयोगकर्तालाई प्रतिक्रिया दिन अनुमति दिन्छ जबकि अलग **workers** यस काम लाई अतुल्यकालीन र विश्वसनीय रूपमा प्रसंस्कृत गर्छन्।

सरल अतुल्यकालीन स्थानान्तरणको परे, Celery ले महत्त्वपूर्ण उत्पादन क्षमताहरू प्रदान गर्छ: **निर्धारित/आवधिक कार्यहरू** (Celery Beat को माध्यमबाट, अनुप्रयोग-स्तरीय अनुसूचन को लागि cron को स्थानापन्न — दैनिक रिपोर्टहरू, सफाई कार्यहरू, आवर्ती सिङ्कहरू), **स्वचालित पुनः प्रयास backoff को साथ** (क्षणिक विफलताहरू विरुद्ध लचीलापन), **कार्य निरन्तरता** (क्यु गरिएका कार्यहरू ब्रोकरको माध्यमबाट पुनः शुरुको माध्यमबाट जीवित रहन्छ, ताकि काम हराउँदैन), र **स्वतन्त्र scaling** वेब सर्भरबाट कार्यकर्ताहरूको।

Celery को आर्किटेक्चर (Redis/RabbitMQ जस्तो ब्रोकर क्यु राख्ने, कार्यहरू प्रसंस्करण गर्ने कार्यकर्ताहरू, नतिजा ब्याकएन्ड), कार्यहरू कसरी परिभाषित र क्यु गर्ने (`@shared_task`, `.delay()`), आवधिक काम अनुसूचन गर्ने, र विश्वसनीयता सुविधाहरू कन्फिगर गर्ने सन्दर्भ समझ गर्नु उत्पादन Django प्रणालीहरू निर्माण गर्न मूल्यवान वरिष्ठ-स्तरीय ज्ञान हो जो भारी वा स्थगित काम सुन्दरतासाथ सम्भाल्छ।

पृष्ठभूमि प्रसंस्करण प्रतिक्रियाशील, मजबूत अनुप्रयोगहरूको लागि एक सामान्य, महत्त्वपूर्ण आवश्यकता हो — र Celery Django पारिस्थितिकीमा वास्तविक मानक समाधान हो — यसमा दक्षता हासिल गर्नु एक व्यावहारिक, बारम्बार-प्रासंगिक कौशल हो जो सरल तुल्यकालीन अनुरोध ह्यान्डलिङ्ग परे वास्तविक-विश्व Django अनुप्रयोगहरू वास्तुकला गर्ने क्षमता प्रतिबिम्बित गर्छ।