Sellerie gibt connection reset by peer

Richte ich das rabbitmqserver und fügte hinzu, die Benutzer mit den folgenden Schritten:

uruddarraju@*******:/usr/lib/rabbitmq/lib/rabbitmq_server-3.2.3$ sudo rabbitmqctl list_users 
Listing users ...
guest   [administrator]
phantom [administrator]
phantom1    []

sudo rabbitmqctl set_permissions -p phantom phantom1 ".*" ".*" ".*"

uruddarraju@******:/usr/lib/rabbitmq/lib/rabbitmq_server-3.2.3$ sudo netstat -tulpn | grep :5672
tcp6       0      0 :::5672                 :::*                    LISTEN      31341/beam.smp

Mein Sellerie config ist wie:

BROKER_URL = 'amqp://phantom:[email protected]/phantom'

Mein code ist wie:

__author__ = 'uruddarraju'

from celery import Celery
import time
import celeryconfig

app = Celery('tasks')
app.config_from_object(celeryconfig)


@app.task
def add(x, y):
    print 'sleeping'
    time.sleep(20)
    print 'awoke'
    return x + y

Wenn ich versuche zu laufen

celery -A celery worker --loglevel=info

Bekomme ich

[2014-07-08 23:30:05,028: ERROR/MainProcess] consumer: Cannot connect to amqp://phantom:**@10.98.85.92:5672/phantom:
[Errno 54] Connection reset by peer.
Trying again in 2.00 seconds...
[2014-07-08 23:30:07,101: ERROR/MainProcess] consumer: Cannot connect to amqp://phantom:**@10.98.85.92:5672/phantom:
[Errno 54] Connection reset by peer.
Trying again in 4.00 seconds...

Alles sieht einfach nur perfekt !! Kann mir jemand helfen, was ich hier vermisst ?

Sie haben port 5672 öffnen? Ist die /phantom Teil der Verbindungs-url korrekt?
Arbeiter, die ja, um zu bestätigen, ich habe eine telnet: LM-SJN-00871893:Aufgaben uruddarraju$ telnet 10.98.85.92 5672 Versuchen 10.98.85.92... Verbunden mit <hostname>. Escape character is '^]'. ^] Die /phantom ist für die virtuellen Hosts die ich erstellt habe, habe ich dieses Dokument hier: [link] (celery.readthedocs.org/en/latest/getting-started/brokers/...)
Werfen Sie einen Blick auf die rabbitmq-log-Datei befindet sich normalerweise unter /var/log/rabbitmq/
=INFO REPORT==== 9-Jul-2014::12:00:00 === die Annahme AMQP-Verbindung <0.401.0> (10.225.82.229:52828 -> 10.98.85.92:5672) =WARNING REPORT==== 9-Jul-2014::12:00:00 === schließen AMQP-Verbindung <0.401.0> (10.225.82.229:52828 -> 10.98.85.92:5672): connection_closed_abruptly =INFO REPORT==== 9-Jul-2014::12:00:12 === die Annahme AMQP-Verbindung <0.405.0> (10.225.82.229:52832 -> 10.98.85.92:5672) =WARNING REPORT==== 9-Jul-2014::12:00:12 === schließen AMQP-Verbindung <0.405.0> (10.225.82.229:52832 -> 10.98.85.92:5672): connection_closed_abruptly @user2027279 Dies ist, was ich sehe, in der Zeitspanne
Keine Kommentare, bitte ?
Hast du zufällig den Namen der Datei celery.py? Ihre Arbeiter Befehl celery -A celery worker --loglevel=info versucht zu starten ein Arbeiter aus einer Datei namens celery.py.
Ja, habe ich, aber das sollte nicht die Hauptursache sein, um die Verbindung zurückgesetzt

InformationsquelleAutor Uday | 2014-07-09

5

Fand ich die Verbindung rest von peer-Fehler, und davon ausgegangen, RabbitMQ war nicht auf den port horcht, oder es gab eine firewall blockiert es. Das war nicht der Fall.

Läuft RabbitMQ auf Ubuntu 16.04.2 LTS-version installiert apt: 3.5.7-1ubuntu0.16.04.1

Die Ausgabe von 'netstat -a' für Kaninchen port 5672 aussah:
```
$ netstat -a|grep -i amqp
tcp6       0      0 [::]:amqp               [::]:*                  LISTEN
```
Aber Kaninchen war in der Tat lauschen auf der IPv4-Adresse und IPv6-Adresse. Ich habe überprüft dies mit netcat.

Erreichen Kaninchen von einer anderen Maschine, Sie müssen ein Benutzerkonto anlegen, mit etwas wie die folgenden Befehle:
```
sudo rabbitmqctl add_user celery celerypassword
sudo rabbitmqctl add_vhost celery_vhost
sudo rabbitmqctl set_user_tags celery celerytag
sudo rabbitmqctl set_permissions -p celery_vhost celery .* .* .*
```
Das Problem war meine URL. Meins sah aus wie:
```
BROKER_URL = 'amqp://celery:[email protected]//'
```
Nachdem das vorletzte Schrägstrich der name des vhost. Oben habe ich meine vhost-name celery_vhost. Zu verbinden, brauchte ich die änderung der URL auf:
```
BROKER_URL = 'amqp://celery:[email protected]/celery_vhost'
```
Entdeckte ich diesen Blick auf die Kaninchen logs in /var/log/rabbitmq. Es gibt eine .log-Datei enthalten ist, wird die folgende Fehlermeldung, wenn ich hatte die falsche URL:
```
{handshake_error,opening,0,
{amqp_error,access_refused,
"access to vhost '/' refused for user 'celery'",
'connection.open'}}
```
- Wenn Sie möchten, um zu prüfen Liste der Benutzer und eine Liste der vhosts, die Sie verwenden können rabbitmqctl list_users und rabbitmqctl list_vhosts
InformationsquelleAutor mbp146520
0

Gelöst wurde das problem, sobald ich mein code bereitgestellt, um die Produktion und Modernisierung der Sellerie 3.1.12. Ich inititally verwendet 3.0.19 aber später aktualisiert und nicht Fragen zu finden. Vielen Dank für die Unterstützung.

InformationsquelleAutor Uday

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.