2017-05-29 3 views
0

Diese nichtDer Versuch, Nachrichten an Kaninchen mq-Server zu veröffentlichen

#!/usr/bin/python 

import pika 

credentials = pika.PlainCredentials('user', 'user') 

parameters = pika.ConnectionParameters('rabbitmqqa2.server.com', 
            15672, 
            '/', 
            credentials) 

connection = pika.BlockingConnection(parameters) 

channel = connection.channel() 

channel.queue_declare(queue='zabbix-mail') 

message = 'Python Queue - Message Sent from sender.py {N|T}' 

channel.basic_publish(exchange='zabbix', 
         routing_key='zabbix-mail-route', 
         body=message) 
print(" [x] Sent 'Hello World!'") 

connection.close() 
+1

werden Sie einen Fehler erhalten, während es läuft? – aksss

+0

"Es funktioniert nicht". Ist keine Frage. Weder ist "was ist los?". Das solltest du uns sagen. –

+0

Sind Sie sicher, dass dies der korrekte Port ist, auf dem Ihr rabbitmq Server tatsächlich läuft? 15672 ist normalerweise der webbasierte Verwaltungsport. Der Standardport, auf dem die Nachrichtenwarteschlange aktiviert ist, ist 5672. – clockwatcher

Antwort

1

arbeitet wie Sie Fehler nicht erwähnt habe, kann ich Ihnen raten, folgende Punkte zu überprüfen.

  1. arbeitet rabbitmq an der angeschlossenen Maschine?
  2. Sie verwenden Port 15672, aber Standardport zum Senden von Nachrichten ist 5672
  3. Standard-Anmeldeinformationen (Benutzername, Kennwort) von rabbitmq ist "Gast" bzw. "Gast".
  4. Da Sie nicht Austausch erklärt werden oder die Bindung an Warteschlange, sollten Sie diese manuell aus rabbitmq Feld (standardmäßig auf 15672 ausgeführt wird) machen
Verwandte Themen