Не удается подключиться от Python Docker к mqtt Docker - PullRequest
Новая
       155

Не удается подключиться от Python Docker к mqtt Docker

3 голосов
/ 05 апреля 2020

Итак, у меня есть контейнер toke / mosquitto docker, к которому я могу подключиться снаружи docker.

Затем я использую контейнер Python docker, который должен публиковаться sh данные моему брокеру комаров. Вот мой код: 

import paho.mqtt.client as paho
import time
import random

broker = "localhost"
port = 1883


def on_publish(client, userdata, result):
    print("Device 1 : Data published.")
    pass

client = paho.Client("admin")
client.on_publish = on_publish
client.connect(broker, port)

for i in range(20):
    d = random.randint(1, 5)

    # telemetry to send
    message = "Device 1 : Data " + str(i)
    time.sleep(d)

    # publish message
    ret = client.publish("/data", message)

print("Stopped...")

Код работает, пытаясь подключиться к брокеру mqtt, не работающему в docker.

Но я не могу понять, как запустить оба с docker и соединяются друг с другом. Мое сообщение об ошибке: 

Traceback (most recent call last):
  File "./pub_client1.py", line 15, in <module>
    client.connect(broker, port)
  File "/usr/local/lib/python3.8/site-packages/paho/mqtt/client.py", line 937, in connect
    return self.reconnect()
  File "/usr/local/lib/python3.8/site-packages/paho/mqtt/client.py", line 1071, in reconnect
    sock = self._create_socket_connection()
  File "/usr/local/lib/python3.8/site-packages/paho/mqtt/client.py", line 3522, in _create_socket_connection
    return socket.create_connection(addr, source_address=source, timeout=self._keepalive)
  File "/usr/local/lib/python3.8/socket.py", line 808, in create_connection
    raise err
  File "/usr/local/lib/python3.8/socket.py", line 796, in create_connection
    sock.connect(sa)
OSError: [Errno 99] Cannot assign requested address

Я уже использую сеть docker. Чего мне не хватает?

Спасибо уже за помощь:)

Ответы [ 2 ]

2 голосов
/ 05 апреля 2020

Как упомянул Фелипе, localhost не будет работать при использовании docker. Вы должны изменить broker = "localhost", чтобы указать службу, которую вы определили в файле docker compose для mqtt или на IP-адрес mqtt при работе в другой сети.

Если ваш docker compose ссылается на файл mqtt как mqtt (mqtt: build mqtt:latest), тогда вам нужно изменить переменную вашего брокера на broker = "mqtt"

1 голос
/ 05 апреля 2020

Этот код пытается соединиться с localhost . Контейнер похож на другой компьютер, поэтому при использовании localhost вы подключаетесь к самому контейнеру.

Этот код необходимо подключить к компьютеру, на котором работает mqtt serve. Вы можете попробовать использовать явный IP-адрес этого компьютера или использовать DNS, если он у вас есть.

...