- [Show pagesource]
- [Old revisions]
- [[unknown link type]]
- []
This is an old revision of the document!
Table of Contents
Celery - Distributed Task Queue
Instalation
- Install RabbitMQ:
aptitude install rabbitmq-server pip install librabbitmq
- Install Celery
sudo pip install Celery
Django Integration
http://celery.readthedocs.org/en/latest/django/first-steps-with-django.html
- Create project celery config:
from __future__ import absolute_import import os from celery import Celery # set the default Django settings module for the 'celery' program. os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'celertest.settings') from django.conf import settings #app = Celery('celertest') app = Celery('celertest', backend='amqp', broker='amqp://guest@localhost//') # Using a string here means the worker will not have to # pickle the object when using Windows. app.config_from_object('django.conf:settings') app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) @app.task(bind=True) def debug_task(self): print('Request: {0!r}'.format(self.request))
python/celery.1434971848.txt.gz · Last modified: 2015/06/22 13:17 by vondra