接口调试

jf_compressed_air.py

@@ -25,7 +25,7 @@ class jf_compressed_air():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(f"{sys_key}_{sys_name}")
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调

jf_pump_center.py

@@ -26,7 +26,7 @@ class jf_pump_center():
 
     def init_mqtt(self):
         # print(self.cf.ip)
-        self.client = mqtt.Client(f"{sys_key}_{sys_name}")
+        self.client = mqtt.Client(f"{self.sys_key}_{self.sys_name}")
         self.client.username_pw_set(self.cf.username, password=self.cf.password)
         # self.client.on_connect = self.on_connect    #连接broker时broker响应的回调
         self.client.on_message = self.on_message    #接收到订阅消息时的回调