Django céleri: Impossible de se connecter à amqp: // [Errno 10054] Une connexion existante a été fermée de force par l'hôte distant

Question

Je me prépare pour la production. Je testais sur OS X et maintenant dans la transition vers Windows 2008. Cela a bien fonctionné pour OS X.

J'ai créé un nouvel utilisateur. Ajout d'un vhost et définition de l'autorisation pour mon utilisateur en utilisant le vhost. Le service RabbitMQ est en cours d'exécution.

jeu d'autorisations: rabbitmqctl set_permissions -p vhost user ".*" ".*" ".*"

je continue à obtenir l'erreur. Je ne sais pas quoi d'autre me manque.

settings.py:

# user, password and vhost are filled properly and do exist in RabbitMQ 
BROKER_URL = 'amqp://user:password@localhost:5672/vhost//' 
CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend' 

celery.py:

app = Celery('myapp', backend='amqp', broker=amqp://user:password@localhost:5672/vhost//) 

python manage.py celery worker --app=myapp.celery --no-color --loglevel=info

sortie:

-------------- celery@inst v3.1.23 (Cipater) 
---- **** ----- 
--- * *** * -- Windows-7-6.1.7601-SP1 
-- * - **** --- 
- ** ---------- [config] 
- ** ---------- .> app:   myapp:0x32b5610 
- ** ---------- .> transport: amqp://user:**@localhost:5672/vhost// 
- ** ---------- .> results: 
- *** --- * --- .> concurrency: 4 (prefork) 
-- ******* ---- 
--- ***** ----- [queues] 
-------------- .> celery   exchange=celery(direct) key=celery 


[tasks] 
    . bpts.tasks.add 
    . bpts.tasks.f 
    . bpts.tasks.mul 
    . bpts.tasks.send_email_message 
    . bpts.tasks.xsum 
    . myapp.celery.debug_task 

[2017-09-08 07:36:56,638: INFO/Worker-1] child process 4776 calling self.run() 
[2017-09-08 07:36:56,966: INFO/Worker-1] child process 5328 calling self.run() 
[2017-09-08 07:36:57,325: INFO/Worker-1] child process 4116 calling self.run() 
[2017-09-08 07:36:57,388: INFO/Worker-1] child process 3720 calling self.run() 
[2017-09-08 07:37:00,013: ERROR/MainProcess] consumer: Cannot connect to amqp:// 
user:**@127.0.0.1:5672/vhost//: [Errno 10054] An existing conne 
ction was forcibly closed by the remote host. 
Trying again in 2.00 seconds... 

Answer 1

Je ne suis pas s ure la solution directe pour le faire fonctionner.

Voici quelques choses que j'ai faites qui ont abouti à ce travail sur mon serveur de production.

origine mon url courtier était amqp://user:password@localhost:5672/vhost// j'ai enlevé la fin //, port # retiré entraînant amqp://user:password@localhost/vhost

Ceci est censé aider le site d'administration pour RabbitMQ rabbitmqctl set_user_tags user administrator

Set autorisation pour vhost racine, je mettre mon propre mais n'a pas semblé travailler donc j'ai essayé ceci. rabbitmqctl set_permissions -p/user ".*" ".*" ".*".

Notez également pour les personnes qui utilisent la production. N'oubliez pas de supprimer l'utilisateur invité.

rabbitmqctl delete_user <user>