Django Celery - Cannot connect to amqp://[email protected]:5672//

49
votes

I'm trying to set up Django-Celery. I'm going through the tutorial

http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html

when I run $ python manage.py celery worker --loglevel=info

I get 

[Tasks]


/Users/msmith/Documents/dj/venv/lib/python2.7/site-packages/djcelery/loaders.py:133:     UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in     production environments!
warnings.warn('Using settings.DEBUG leads to a memory leak, never '

[2013-08-08 11:15:25,368: WARNING/MainProcess] /Users/msmith/Documents/dj/venv/lib/python2.7/site-packages/djcelery/loaders.py:133: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments!
warnings.warn('Using settings.DEBUG leads to a memory leak, never '

[2013-08-08 11:15:25,369: WARNING/MainProcess] celery@sfo-mpmgr ready.
[2013-08-08 11:15:25,382: ERROR/MainProcess] consumer: Cannot connect to     amqp://[email protected]:5672/celeryvhost: [Errno 61] Connection refused.
Trying again in 2.00 seconds...

has anyone encountered this issue before?

settings.py

# Django settings for summertime project.
import djcelery
djcelery.setup_loader()

BROKER_URL = 'amqp://guest:guest@localhost:5672/'

...

INSTALLED_APPS = {
    ...
    'djcelery',
    'celerytest'
}

wsgi.py

import djcelery
djcelery.setup_loader()
7
pythondjangocelery
could you confirm if your rabbitmq service is running? check out this guide it has step by step instructions: hairycode.org/2013/07/23/… - andrean
celery need message broker. I think you missed the message broker setting. you need to install rabbitmq. after installation, you need to make vhost, user and set permissions. - Curry

7 Answers

30
votes

The problem is that you are trying to connect to a local instance of RabbitMQ. Look at this line in your settings.py

BROKER_URL = 'amqp://guest:guest@localhost:5672/'

If you are working currently on development, you could avoid setting up Rabbit and all the mess around it, and just use a development version of a message queue with the Django database.

Do this by replacing your previous configuration with:

BROKER_URL = 'django://'

...and add this app:

INSTALLED_APPS += ('kombu.transport.django', )

Finally, launch the worker with:

./manage.py celery worker --loglevel=info

Source: http://docs.celeryproject.org/en/latest/getting-started/brokers/django.html

21
votes

I got this error because rabbitmq was not started. If you installed rabbitmq via brew you can start it using brew services start rabbitmq

5
votes

you can add these lines to your settings.py :

CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'

and run :

celery -A yourProjectName worker -l info
4
votes

If you are workling on a production environment,

You have to first install and setup a rabbitmq server. You can refer rabbitmq website for installation steps.

In settings you have to write this lines:

CELERY_RESULT_BACKEND='djcelery.backends.database:DatabaseBackend',
BROKER_URL = 'amqp://guest:guest@localhost:5672//'

After all setup of rabitmq server you have to run this two command,

export C_FORCE_ROOT='true'
celery -A transcoder(name of app) worker --loglevel=info
0
votes

If all above solutions are not working, you can try with this: turn off your network connection (wifi or wire).

It's so weird but sometime it's work for me!

Seem it relates to the local network device instead of RabbitMQ service.

My screen recording: https://drive.google.com/file/d/13t35Lzh3JLsCbGjRag0uiDhcYz1JuHq7/view?usp=sharing

0
votes

Make sure you run the rabbit server in global, in my case that was the issue.

0
votes

This error means celery backend settings is not proper so it is not able to connect to backend.

If you just started tutorial celery with django . You can try below settings.

CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672//'
CELERY_RESULT_BACKEND = 'db+sqlite:///results.db'