rabbitmq connect

rmq.py

In [24]: node = pika.URLParameters('amqps://<>.mq.us-east-1.amazonaws.com:5671')

In [25]: conn = pika.BlockingConnection([node])
Pika version 1.1.0 connecting to ('<>', 5671)
Socket connected: <socket.socket fd=17, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('192.168.178.45', 50679), raddr=('<>', 5671)>
SSL handshake completed successfully: <ssl.SSLSocket fd=17, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('192.168.178.45', 50679), raddr=('<>', 5671)>
Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncSSLTransport object at 0x110918ee0>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncSSLTransport object at 0x110918ee0> params=<URLParameters host=<>.mq.us-east-1.amazonaws.com port=5671 virtual_host=/ ssl=True>>).
Aborting transport connection: state=1; <ssl.SSLSocket fd=17, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('192.168.178.45', 50679), raddr=('<>', 5671)>
_AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None; <ssl.SSLSocket fd=17, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('192.168.178.45', 50679), raddr=('<>', 5671)>
Deactivating transport: state=1; <ssl.SSLSocket fd=17, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('192.168.178.45', 50679), raddr=('<>', 5671)>
AMQP stack terminated, failed to connect, or aborted: opened=False, error-arg=None; pending-error=ConnectionClosedByBroker: (403) 'ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile.'
    
    
    #OR this call
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials("user", "password")))

    

Double check the subnet your borker is launched in and if the routing is set properly for that subnet.