carrot-为 Django 打造的 Celery 替代品
carrot-为 Django 打造的 Celery 替代品
Python Web开发框架
共14Star
详细介绍
Carrot -- A simple task queue for Django
Why this was made:
- It's very easy to use.
- It decouples the task code from the task manager code.
Quick Setup:
- Install rabbitmq-server (default on localhost)
yum install rabbitmq-server
service rabbitmq-server start
- Install carrot
pip install djangocarrot
manage.py makemigrations carrot
manage.py migrate carrot
- Add carrot to installed apps (settings.py)
INSTALLED_APPS = ['carrot']
Basic Usage:
from carrot.models import Task
Task.objects.create(kallable="myapp.mymodule.mykallable")
Task arguments:
- kallable (required): location to callable, e.g. animals.Dog.bark
- args (optional): list of positional arguments to pass to the callable
- kwargs (optional): map of key/value pairs to pass to the callable
- worker (optional): request a specific worker to execute task
Consume tasks
The tasks need to be consumed. This can easily be accomplished with the WorkerService
from carrot.utils import WorkerService
WorkerService().start()
The worker service can also be daemonized with a management command manage.py carrot-workers
Workers (Advanced Usage)
A default worker is already available to use for tasks and this step is not necessary. However, new workers may be created to handle specific tasks. For example, let's say you need a worker which only processes one task at a time so as not to overwhelm some system resource.
from carrot.models import Worker, Task
worker = Worker(name='fileprocesser')
worker.description = 'Used for processing large files one at a time'
worker.concurrency = 1
worker.save()
Task.objects.create(kallable='example.processFile', args=['/tmp/huge1.wav'], kwargs={'bitrate': 1411}, worker=worker)
Task.objects.create(kallable='example.processFile', args=['/tmp/huge2.wav'], kwargs={'bitrate': 1411}, worker=worker)
Task.objects.create(kallable='example.processFile', args=['/tmp/huge3.wav'], kwargs={'bitrate': 1411}, worker=worker)
Worker arguments:
- name (required): an arbitrary name to identify the worker
- description (optional): a description of worker and it's duties
- concurrency (optional) (default -> 4): how many tasks this worker can process concurrently
- enabled (optional) (default: True): whether or not this worker should be processing tasks