৬. প্রাকটিক্যাল করি

django-admin startproject project_name

cd project_name

python manage.py startapp app_name

INSTALLED_APPS = [
  'app_name',

]

python manage.py migrate 

# app_name/views.py

from django.http import HttpResponse

def index(request):
    return HttpResponse("Hello from my view!")

# app_name/urls.py

from django.urls import path

from . import views

urlpatterns = [

path('', views.index, name='index'),

]

# project_name/urls.py

from django.contrib import admin

from django.urls import path, include # Import the include function

urlpatterns = [

path('admin/', admin.site.urls),

path('', include('app_name.urls')), # Include the app's URLs

]

python manage.py runserver

pip install  celery redis django-celery-results django-celery-beat

INSTALLED_APPS = [
   'django_celery_results',
   'django_celery_beat'

]

python manage.py migrate 

from __future__ import absolute_import, unicode_literals
import os

from celery import Celery

# Set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project_name.settings')

app = Celery('project_name')

# 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()


@app.task(bind=True, ignore_result=True)
def debug_task(self):
    print(f'Request: {self.request!r}')

from .celery import app as celery_app

__all__ = ('celery_app',) 

# Celery settings
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'django-db'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'UTC'
CELERY_ENABLE_UTC = True

# app_name/tasks.py


from celery import shared_task
import time

@shared_task
def print_numbers():
    for i in range(1, 11):
        print(f"Number: {i}")
        time.sleep(1)  # Sleep for 1 second between each print


    

from django.shortcuts import render
from django.http import HttpResponse  # Import HttpResponse

from .tasks import print_numbers


def print_numbers_view(request):
    # Use Celery task to print numbers asynchronously
    print_numbers.delay()

    return HttpResponse  ('email_sent.html')

from django.urls import path

from . import views

urlpatterns = [

path('', views.print_numbers_view, name='print_numbers_view'),

]

CELERY_BEAT_SCHEDULE = {
    'print_numbers': {
        'task': 'app_name.tasks.print_numbers',
        'schedule': 300.0,  # Run every 5 minutes (300 seconds)
    },
}

celery -A project_name worker -l info 
celery -A project_name beat -l info