celery 2.4.5

celery is a distributed task queue framework for Django.<br /><br />Installation<br /><br />You can install celery either via the Python Package Index (PyPI) or from source.<br /><br />To install using pip,:<br /><br />$ pip install celery<br /><br />To install using easy_install,:<br /><br />$ easy_install celery<br /><br />If you have downloaded a source tarball you can install it by doing the following,:<br /><br />$ python setup.py build<br /># python setup.py install # as root<br /><br />Usage<br /><br />Have to write a cool tutorial, but here is some simple usage info.<br /><br />Note You need to have a AMQP message broker running, like RabbitMQ, and you need to have the amqp server setup in your settings file, as described in the carrot distribution README.<br /><br />Note If you're running SQLite as the database backend, celeryd will only be able to process one message at a time, this because SQLite doesn't allow concurrent writes.<br /><br />Defining tasks<br /><br /> >>> from celery.task import tasks<br /> >>> from celery.log import setup_logger<br /> >>> def do_something(some_arg, **kwargs):<br /> ... logger = setup_logger(**kwargs)<br /> ... logger.info("Did something: %s" % some_arg)<br /> >>> task.register(do_something, "do_something")<br /><br />Note Task functions only supports keyword arguments.<br />Tell the celery daemon to run a task<br /><br /> >>> from celery.task import delay_task<br /> >>> delay_task("do_something", some_arg="foo bar baz")<br /><br />Running the celery daemon<br /><br />$ cd mydjangoproject<br />$ env DJANGO_SETTINGS_MODULE=settings celeryd<br />[....]<br />[2009-04-23 17:44:05,115: INFO/Process-1] Did something: foo bar baz<br />[2009-04-23 17:44:05,118: INFO/MainProcess] Waiting for queue.<br /><br />Autodiscovery of tasks<br /><br />celery has an autodiscovery feature like the Django Admin, that automatically loads any tasks.py module in the applications listed in settings.INSTALLED_APPS.<br /><br />A good place to add this command could be in your urls.py,<br /><br />from celery.task import tasks<br />tasks.autodiscover()<br /><br />Then you can add new tasks in your applications tasks.py module,<br /><br />from celery.task import tasks<br />from celery.log import setup_logger<br />from clickcounter.models import ClickCount<br /><br />def increment_click(for_url, **kwargs):<br /> logger = setup_logger(**kwargs)<br /> clicks_for_url, cr = ClickCount.objects.get_or_create(url=for_url)<br /> clicks_for_url.clicks = clicks_for_url.clicks + 1<br /> clicks_for_url.save()<br /> logger.info("Incremented click count for %s (not at %d)" % (<br /> for_url, clicks_for_url.clicks)<br />tasks.register(increment_click, "increment_click")<br /><br />Periodic Tasks<br /><br />Periodic tasks are tasks that are run every n seconds. They don't support extra arguments. Here's an example of a periodic task:<br /><br /> >>> from celery.task import tasks, PeriodicTask<br /> >>> from datetime import timedelta<br /> >>> class MyPeriodicTask(PeriodicTask):<br /> ... name = "foo.my-periodic-task"<br /> ... run_every = timedelta(seconds=30)<br /> ...<br /> ... def run(self, **kwargs):<br /> ... logger = self.get_logger(**kwargs)<br /> ... logger.info("Running periodic task!")<br /> ...<br /> >>> tasks.register(MyPeriodicTask)<br /><br />For periodic tasks to work you need to add celery to INSTALLED_APPS, and issue a syncdb.<br /><br />md5=0545f89033e1639bbb1be0974465577c

Requirements:	No special requirements
Platforms:	*nix, Linux
Keyword:	Applications,  Command,  Increment Clickfor Url,  Listed,  Loads,  Module,  Place,  Settingsinstalled Apps,  Taskspy
Users rating:	0/10