Azure IoT Hub: el código de "Suscripción" no funciona: "se rechazó la conexión"
ntento recibir "notificaciones" de IoT Hub cuando se publican algunos datos en el tema MQTTdevices/device_id/messages/events/
. Para recibir datos, estoy usando el siguiente tema:devices/device_id/messages/devicebound/
. Mi código de suscripción está debajo (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()
Cuando corro, obtengo el siguiente resultado:
Conectando a Azure IoT Hub ...
Conectado con estado: 3
('on_disconnect', 'Se produjo un error. 5: Se rechazó la conexión')
Conectado con estado: 3
('on_disconnect', 'Se produjo un error. 5: Se rechazó la conexión')
¿Alguien puede sugerir lo que me estoy perdiendo?