python paho mqtt не может подключиться к mqtts с логином и паролем

Question

Следующий код python на моем raspberrypi не подключается к моему брокеру mqtt, он просто зависает после печати Connecting...:

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe("test")


def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))


client = mqtt.Client(client_id="",clean_session=True,userdata=None,protocol=mqtt.MQTTv311,transport="tcp")
client.on_connect = on_connect
client.on_message = on_message

client.username_pw_set(username="stackoverflow",password="stackoverflow")
print("Connecting...")
client.connect("learn.evermight.net", 9101, 10)
client.loop_forever()

Что я сделал не так с моим кодом Python ?

---

Успешно в командной строке

Я подтвердил, что мой mqtt работает, потому что я могу подписаться с терминала с помощью этой команды:

mosquitto_sub -h learn.evermight.net -p 9101 -t "test" -u "stackoverflow" -P "stackoverflow" --capath /etc/ssl/certs/

И я увижу сообщения в своем терминале, как только запущу эту команду с другого терминала

mosquitto_pub -h learn.evermight.net -p 9101 -t "test" -u "stackoverflow" -P "stackoverflow" -m "hello world" --capath /etc/ssl/certs/

Что не так с моим кодом python?

---

NodeJS Успех

Кроме того, следующий код NodeJS также работает для подключения и публикации на моем сервере MQTT.

const mqtt = require('async-mqtt');

  try{
    const client = await mqtt.connectAsync("mqtts://learn.evermight.net",{
      port:9101,
      host:"mqtts://learn.evermight.net",
      username:"stackoverflow",
      password:"stackoverflow",
      connectTimeout:5000,
      protocolId:"MQIsdp",
      protocolVersion:3,
      encoding:"utf8",
      keepalive: 60
    });
    await client.publish("test","hello world");
    await client.end();
  } catch(e) {
    console.log(e);
  }

---

Веб-сайт JavaScript Успешно

И следующий код также может подключаться к порту веб-сокета через веб-браузер javascript, подписываться на test topi c и получать опубликованные сообщения (обратите внимание, что мои веб-сокеты используют порт 9102)

import Paho from "paho-mqtt";

const client = new Paho.Client("learn.evermight.net",9102,"WebBrowser");
  client.onConnectionLost = response=>console.log("lostMQTTConnection: " +(response.errorCode !== 0 ? response.errorMessage : "Unknown MQTT Error" ));
  client.onMessageArrived = message=>console.log(message.payloadString);
  client.connect({
    onSuccess:_=>client.subscribe("test"),
    useSSL:true,
    userName:"stackoverflow",
    password:"stackoverflow",
  });

Answer 1

Я обнаружил, что могу подключиться, если добавлю эту команду без аргументов

client.tls_set()

---

В документации paho в конце описания для tls_set() вы можете увидеть

Must be called before connect*().

но это работает для меня событие после client.connect()

---

В той же документации вы можете видеть, что без аргументов он использует системные настройки по умолчанию

By default, on Python 2.7.9+ or 3.4+,  
the default certification authority of the system is used. 

On older Python version this parameter is mandatory.

---

Требуется, только если mosquitto_sub / mosquitto_pub требует --capath /etc/ssl/certs/.
Если mosquitto_sub / mosquitto_pub работает без --capath /etc/ssl/certs/, то не используйте

---

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code", rc)
    client.subscribe("test")

def on_message(client, userdata, msg):
    print(msg.topic, msg.payload)


client = mqtt.Client(client_id="", clean_session=True, userdata=None, protocol=mqtt.MQTTv311, transport="tcp")
client.on_connect = on_connect
client.on_message = on_message

client.tls_set()  # <--- even without arguments

client.username_pw_set(username="stackoverflow", password="stackoverflow")
print("Connecting...")
client.connect("learn.evermight.net", 9101, 10)
client.loop_forever()