Celery and Django simple example
Assuming you have both Python's celery and django-celery installed, create the following tasks.py
file under your app:
utils/tasks.py
from celery import task# other imports@task()def create_user(data): user = User.objects.create_user( username=data['username'], email=None, password=data['password'] ) user.save() profile = UserProfile() profile.user = user profile.token = generate_token() profile.save() return None
Delete your utils/utilities.py
file in your example above.
In your code in views.py
change the create_user
call from:
create_user(form.cleaned_data)
to:
create_user.delay(form.cleaned_data)
Basically create_user
is now a celery task; if you have the right Python packages installed (as mentioned above), code-wise (the implementation you ask for) that's it. delay
executes your function asynchronously - i.e. the HTTP response is returned without waiting for the asynchronous task to complete.
Locally you can run a celery daemon process using python manage.py celeryd
.
In production you have to set up the celery process itself using for instance upstart
, supervisor
or any other tool to control the lifecycle of such process.
Further details documented here.