Hub IoT do Azure - o código "Inscrever-se" não está funcionando: "a conexão foi recusada"
Estou tentando receber "notificações" do Hub IoT quando alguns dados são publicados no tópico MQTTdevices/device_id/messages/events/
. Para receber dados, estou usando o seguinte tópico:devices/device_id/messages/devicebound/
. Meu código de inscrição está abaixo (Python):
import paho.mqtt.client as mqtt
import ssl, random
from time import sleep
root_ca = "./certs/digicertbaltimoreroot.pem"
public_crt = './certs/rsa_cert.pem'
private_key = './certs/rsa_private.pem'
iothub_name = "myhub"
device_id = "mydevice"
mqtt_url = "{}.azure-devices.net".format(iothub_name)
mqtt_port = 8883
topic = "devices/{}/messages/devicebound/#".format(device_id)
def error_str(rc):
return "Some error occurred. {}: {}".format(rc, mqtt.error_string(rc))
def on_disconnect(unused_client, unused_userdata, rc):
print("on_disconnect", error_str(rc))
def on_connect(client, userdata, flags, response_code):
print("Connected with status: {0}".format(response_code))
client.subscribe(topic, 1)
def on_subscribe(client, userdata, mid, granted_qos):
print("Subscribed: "+str(mid)+" "+str(granted_qos))
def on_message(client, userdata, msg):
print("Topic: {0} -- Payload: {1}".format(msg.topic, str(msg.payload)))
if __name__ == "__main__":
client = mqtt.Client(device_id, protocol=mqtt.MQTTv311)
client.tls_set(root_ca,
certfile = public_crt,
keyfile = private_key,
cert_reqs = ssl.CERT_REQUIRED,
tls_version = ssl.PROTOCOL_TLSv1_2,
ciphers = None)
client.on_connect = on_connect
client.on_message = on_message
client.on_disconnect = on_disconnect
print("Connecting to Azure IoT Hub...")
client.connect(mqtt_url, mqtt_port, keepalive=60)
client.loop_forever()
Quando executo, estou obtendo a seguinte saída:
Conectando ao Hub IoT do Azure ...
Conectado com o status: 3
('on_disconnect', 'Ocorreu um erro. 5: A conexão foi recusada.')
Conectado com o status: 3
('on_disconnect', 'Ocorreu um erro. 5: A conexão foi recusada.')
Alguém pode sugerir o que estou perdendo?