无法从Python Docker连接到mqtt Docker

问题描述 投票:1回答:1

所以我运行了一个toke / mosquitto docker容器,可以从外部docker连接到该容器。

然后,我使用的是Python泊坞窗容器,该容器应将数据发布到我的mosquitto代理。这是我的代码:

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...")

代码尝试连接到不在docker中运行的mqtt代理。

但是我不知道如何让两者都与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网络。我想念什么?

已经感谢您的帮助:)

docker docker-compose mqtt mosquitto docker-network
1个回答
0
投票

该代码正在尝试与localhost连接。容器就像另一台计算机,因此,当您使用localhost时,您正在与容器本身进行连接。

© www.soinside.com 2019 - 2024. All rights reserved.