【发布时间】:2023-01-15 06:48:25
【问题描述】:
我有一个连接到 WSS MQTT 端点的 Python 脚本,如下所示:
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
if str(rc) == "0":
print(" Connection successful")
client.subscribe("myqueue")
client = mqtt.Client(transport="websockets")
client.ws_set_options(path="/my/path", headers={"Authorization": "Bearer ..."})
client.on_connect = on_connect
client.tls_set()
client.connect("my_endpoint.com",443)
但是一旦调用client.subscribe(或publish),套接字就会关闭并断开连接,代码为 7(这是 Unexpected Disconnect 的 MQTT 错误)。
有没有人见过这个或知道如何规避这个问题?如果我从不拨打subscribe或publish,连接将保持打开状态。
【问题讨论】:
-
在您的代码中没有处理传入和传出数据的网络循环