Я пытаюсь подключиться к удаленному экземпляру 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