Assigning Tasks Using Celery In Django

Posted By : Sakib Raza | 26-Jul-2023



Why Use Celery?

1. Offloading running task

2. Sending bulk emails

3. Periodic task

4. Background task

5. Task routing

First of all, you haveto install Celery using the following commands:

- - pip install celery

- - pip install django-celery-beat

Note: Make sure you havealready installed Django

Also, ReadTenant Schema In Python Django

After that below changes add 'celery' in installed apps in the Django file

- - 'celery' in installed apps

- - CELERY_BROKER_URL ='redis://localhost:6379/0'


-- CELERY_CACHE_BACKEND ='django-cache'

Also, you haveto install redis: pip install django-redis

After that, you haveto add changes in file ofroot directory. changes :

We will need to import Celery and create an instance of the Celery class.We will also need to set the Django settings module as an environment variable so that Celery knows how to connect to our Django project.
Next, we will need to define our tasks in thecelery.pyfile from .celery import app as celery_app

__all__ = ('celery_app',)

And also you've to create in the root directory

Create a Celery instance in the root directory: changes:-

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project_name.settings')
app = Celery('Project_name', broker_connection_retry_on_startup=True)
app.config_from_object('django.conf:settings', namespace='CELERY')


Note:  broker_connection_retry_on_startup=True this change is required in celery new version

Also, ReadDjango vs Flask: Neck To Neck Comparison

For running tasks in the background:

Define tasks in one or more Django app modules. In the application directory, create a file called
This is where we will define our Celery tasks and define our tasks using the @shared_task decorator, but it’s a good idea to create a separate app for them.

from celery import shared_task
def add(x, y):
return x + y

And for running tasks in background, you haveto call a function with .delay like the below method

from myapp.tasks import add
result = add.delay(2, 3)

And for scheduling tasks for a particular time or periodic tasks -:

Define the function as per your need.

def add(x, y)
return x+y
and add these changes in the file
    'background_task': {
        'task': 'core.auto_gpt_on.auto_gpt_on',
        'schedule': crontab(hour=12, minute=0),  # Schedule at 12:00 PM
And after that run these commands for the scheduled task - :
Cmd for celery worker - 'celery -A project_name worker -l INFO'
Cmd for celery beat - 'celery -A project_name beat -l INFO'   # if using the periodic task feature
After that, your task is scheduled for a specific time period.