Pika & Amazon MQ error

Question

Сейчас я ищу пример кода на python и amazon-mq. Вот что я использую, но это не работает. Если кто-то знает исходный код ссылки и ошибки ниже. Пожалуйста, оставьте комментарий.

Заранее спасибо.

import pika
import logging

logging.basicConfig(level=logging.DEBUG)

credentials = pika.PlainCredentials('id', 'password')
parameters =  pika.ConnectionParameters('amqp://aws-address', port=5671, credentials=credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.exchange_declare(exchange="test_exchange", exchange_type="direct",
                         passive=False, durable=True, auto_delete=False)

print("Sending message to create a queue")
channel.basic_publish('test_exchange', 'standard_key', 'queue:group',
                      pika.BasicProperties(content_type='text/plain',
                                           delivery_mode=1))

connection.sleep(5)

print("Sending text message to group")
channel.basic_publish('test_exchange', 'group_key', 'Message to group_key',
                      pika.BasicProperties(content_type='text/plain',
                                           delivery_mode=1))

connection.sleep(5)

print("Sending text message")
channel.basic_publish('test_exchange', 'standard_key', 'Message to standard_key',
                      pika.BasicProperties(content_type='text/plain',
                                           delivery_mode=1))

connection.close()

И я добавляю код ошибки.

Connected to pydev debugger (build 171.4694.38)
Traceback (most recent call last):
  File "/Applications/PyCharm CE.app/Contents/helpers/pydev/pydevd.py", line 1591, in <module>
    globals = debugger.run(setup['file'], None, None, is_module)
  File "/Applications/PyCharm CE.app/Contents/helpers/pydev/pydevd.py", line 1018, in run
    pydev_imports.execfile(file, globals, locals)  # execute the script
  File "/Applications/PyCharm CE.app/Contents/helpers/pydev/_pydev_imps/_pydev_execfile.py", line 18, in execfile
    exec(compile(contents+"\n", file, 'exec'), glob, loc)
  File "/Users/hsboee/private/active-mq/consumer.py", line 24, in <module>
    connection = pika.BlockingConnection(parameters)
  File "/Users/hsboee/private/active-mq/.venv/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 374, in __init__
    self._process_io_for_connection_setup()
  File "/Users/hsboee/private/active-mq/.venv/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 414, in _process_io_for_connection_setup
    self._open_error_result.is_ready)
  File "/Users/hsboee/private/active-mq/.venv/lib/python3.6/site-packages/pika/adapters/blocking_connection.py", line 466, in _flush_output
    raise maybe_exception
  File "/Users/hsboee/private/active-mq/.venv/lib/python3.6/site-packages/pika/adapters/base_connection.py", line 157, in _adapter_connect
    socket.IPPROTO_TCP)
  File "/Users/hsboee/private/active-mq/.venv/lib/python3.6/site-packages/pika/adapters/base_connection.py", line 283, in _getaddrinfo
    return socket.getaddrinfo(host, port, family, socktype, proto)
  File "/Library/Frameworks/Python.framework/Versions/3.6/lib/python3.6/socket.py", line 743, in getaddrinfo
    for res in _socket.getaddrinfo(host, port, family, type, proto, flags):
socket.gaierror: [Errno 8] nodename nor servname provided, or not known