Celery

pip install celery

- proj/
  - manage.py
  - proj/
    - __init__.py
    - settings.py
    - urls.py

import os

from celery import Celery

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

app = Celery('proj')

# 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}')

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proj.settings')

app = Celery('proj')

# 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',)

pip install django-celery-results

# settings.py

INSTALLED_APPS = [
    'django_celery_results',
]
# Celery configuration
CELERY_RESULT_BACKEND = 'django-db'

CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

pip install --upgrade redis

# Celery configuration
CELERY_BROKER_URL = 'redis://localhost:6379/0'  # Use the URL of your message broker (e.g., Redis)

python manage.py migrate

# tasks.py

from celery import shared_task
@shared_task
def test_task():
    for i in range(1,10):
        print(f"Number: {i}")

# views.py

from .tasks import test_task
def test(request):
    result = test_task.delay()
    return HttpResponse("done")

from django.urls import path
from . import views

urlpatterns = [
    path('test/', views.test, name='test'),    
]

celery -A project_name worker -l info 

pip django-celery-beat

INSTALLED_APPS = [
    ...
    'django_celery_beat',
]

python manage.py migrate

#settings.py

#Configure Celery Beat Scheduler:
CELERY_BEAT_SCHEDULE = {
    'my_task': {
        'task': 'myapp.tasks.my_task',
        'schedule': 300.0,  # Run every 5 minutes (300 seconds)
    },
}

# Configure Celery Beat Settings:
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'
CELERY_BEAT_LOG_LEVEL = 'INFO'

celery -A myproject worker -l info -B

from celery import shared_task
@shared_task
def test_task():
    for i in range(1,10):
        print(f"Number: {i}")

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

#Celery Beat Settings  
app.conf.beat_schedule = {  
    'send-mail-every-day-at-8' :  {  
        'task': 'emailExample.tasks.send_mail_func',  
        'schedule': crontab(hour = 15, minute = 42),  
  
    }  
      
}  

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