Running periodic tasks with django and celery

Question

I'm trying create a simple background periodic task using Django-Celery-RabbitMQ combination. I installed Django 1.3.1, I downloaded and setup djcelery. Here is how my settings.py file looks like: ``` BROKER_HOST = "127.0.0.1" BROKER_PORT = 5672 BROKER_VHOST = "/" BROKER_USER = "guest" BROKER_PASSWORD = "guest" .... import djcelery djcelery.setup_loader() ... INSTALLED_APPS = ( 'djcelery', ) ``` And I put a 'tasks.py' file in my application folder with the following contents: ``` from celery.task import PeriodicTask from celery.registry import tasks from datetime import timedelta from datetime import datetime class MyTask(PeriodicTask): run_every = timedelta(minutes=1) def run(self, **kwargs): self.get_logger().info("Time now: " + datetime.now()) print("Time now: " + datetime.now()) tasks.register(MyTask) ``` And then I start up my django server (local development instance): ``` python manage.py runserver ``` Then I start up the `celerybeat` process: ``` python manage.py celerybeat --…

Accepted Answer

Celerybeat it stuff, which pushes task when it need, but not executing them. You tasks instances stored in RabbitMq server. You need to execute celeryd daemon for executing your tasks.

```
python manage.py celeryd --logfile=<path_to_log_file> -l DEBUG
```

Also if you using RabbitMq, I recommend to you to install special rabbitmq management plugins:

```
rabbitmq-plugins list
rabbitmq-enable rabbitmq_management
service rabbitmq-server restart
```

It will be available at http://:55672/ login: guest pass: guest. Here you can check how many tasks in your rabbit instance online.

Running periodic tasks with django and celery

Solution

Problem