Ошибки подключения к удаленному экземпляру rabbitmq с использованием SSL при использовании модуля pika python

Я пытаюсь подключиться к удаленному экземпляру rabbitmq, используя SSL. Я решил использовать модуль pika, так как он кажется наиболее широко используемым модулем. У меня есть cacert с удаленного сервера, и я не теряю связь, если нет однорангового сертификата. Я также использую самозаверяющий сертификат и не проверяю сертификат на стороне сервера. Несмотря на все это, я продолжаю получать ошибки подключения. Я знаю, что, вероятно, просто неправильно настраиваю параметры, но я уже несколько дней мучаюсь с этой проблемой. Как правильно настроить параметры для подключения к моему экземпляру rabbitmq?

Вот конфигурация моего сервера rabbitmq

  {rabbit,
    [
      { tcp_listeners, [ 5672 ] },
      { ssl_listeners, [ 5671 ] },
      { ssl_options,  [
        { certfile,   "/etc/rabbitmq/ssl/cert.pem" },
        { keyfile,    "/etc/rabbitmq/ssl/key.pem" },
        { cacertfile, "/etc/rabbitmq/ssl/cacert.pem" },
        { verify,   verify_none },
        { fail_if_no_peer_cert, false } ] },
      {default_user, <<"guest">>},
      {loopback_users, []}
    ]

и вот код, который я пытаюсь

server = "server"
port = 5671
caCert = "./cacert.pem"
context = ssl.create_default_context(cafile="./cacert.pem")
ssl_options = pika.SSLOptions(context, server)
parameters = pika.ConnectionParameters(host=server, port=port, ssl_options=ssl_options)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()

Я ожидаю получить 0 ошибок при запуске этого кода, но я продолжаю получать ту или иную форму этой ошибки:

Traceback (most recent call last):
  File "test.py", line 11, in <module>
    connection = pika.BlockingConnection(parameters)
  File "/Library/Python/2.7/site-packages/pika/adapters/blocking_connection.py", line 360, in __init__
    self._impl = self._create_connection(parameters, _impl_class)
  File "/Library/Python/2.7/site-packages/pika/adapters/blocking_connection.py", line 451, in _create_connection
    raise self._reap_last_connection_workflow_error(error)
pika.exceptions.AMQPConnectionError

person aslangfo    schedule 13.05.2019    source источник


Ответы (1)


На самом деле это оказалось проблемой брандмауэра.

person aslangfo    schedule 13.05.2019