@@ -111,6 +111,8 @@ def _gen_sas_token(self) -> str:
111
111
def _create_mqtt_client (self ) -> None :
112
112
minimqtt .set_socket (self ._socket , self ._iface )
113
113
114
+ self ._logger .debug (str .replace (f'- iot_mqtt :: _on_connect :: username = { self ._username } , password = { self ._passwd } ' , '%' , '%%' ))
115
+
114
116
self ._mqtts = MQTT (
115
117
broker = self ._hostname ,
116
118
username = self ._username ,
@@ -121,12 +123,10 @@ def _create_mqtt_client(self) -> None:
121
123
client_id = self ._device_id ,
122
124
)
123
125
124
- self ._mqtts .logger = self ._logger
125
- self ._mqtts .logger .setLevel (self ._logger .getEffectiveLevel ())
126
+ self ._mqtts .enable_logger (logging , self ._logger .getEffectiveLevel ())
126
127
127
128
# set actions to take throughout connection lifecycle
128
129
self ._mqtts .on_connect = self ._on_connect
129
- self ._mqtts .on_log = self ._on_log
130
130
self ._mqtts .on_publish = self ._on_publish
131
131
self ._mqtts .on_disconnect = self ._on_disconnect
132
132
@@ -146,12 +146,6 @@ def _on_connect(self, client, userdata, _, rc) -> None:
146
146
self ._auth_response_received = True
147
147
self ._callback .connection_status_change (True )
148
148
149
- # pylint: disable=C0103, W0613
150
- def _on_log (self , client , userdata , level , buf ) -> None :
151
- self ._logger .info ("mqtt-log : " + buf )
152
- if level <= 8 :
153
- self ._logger .error ("mqtt-log : " + buf )
154
-
155
149
def _on_disconnect (self , client , userdata , rc ) -> None :
156
150
self ._logger .info ("- iot_mqtt :: _on_disconnect :: rc = " + str (rc ))
157
151
self ._auth_response_received = True
@@ -348,7 +342,7 @@ def __init__(
348
342
self ._hostname = hostname
349
343
self ._key = key
350
344
self ._token_expires = token_expires
351
- self ._username = "{}/{}/api-version={}" .format (
345
+ self ._username = "{}/{}/? api-version={}" .format (
352
346
self ._hostname , device_id , constants .IOTC_API_VERSION
353
347
)
354
348
self ._passwd = self ._gen_sas_token ()
0 commit comments