object detection: revise

opencv-yolo/web/web.py

@@ -167,6 +167,7 @@ class VAMMQTTClient:
     rabChanAiTask = None
     th1 =None
     th2 = None
+    client = None
     # The callback for when the client receives a CONNACK response from the server.
     @staticmethod
     def on_connect(client, userdata, flags, rc):
@@ -204,14 +205,15 @@ class VAMMQTTClient:
         '''
         Parameters
         '''
-        self.client = mqtt.Client(
-            MQTT_CID if MQTT_CID else "vamqtt", userdata=callback)  # , protocol=mqtt.MQTTv5)
-        if MQTT_USER and MQTT_PASSWORD:
-            self.client.username_pw_set(username=MQTT_USER,password=MQTT_PASSWORD)
-        self.client.on_connect = VAMMQTTClient.on_connect
-        self.client.on_message = VAMMQTTClient.on_message
-        self.client.connect_async(host, port, 30)
-        self.client.loop_start()
+        if MQTT_HOST:
+            self.client = mqtt.Client(
+                MQTT_CID if MQTT_CID else "vamqtt", userdata=callback)  # , protocol=mqtt.MQTTv5)
+            if MQTT_USER and MQTT_PASSWORD:
+                self.client.username_pw_set(username=MQTT_USER,password=MQTT_PASSWORD)
+            self.client.on_connect = VAMMQTTClient.on_connect
+            self.client.on_message = VAMMQTTClient.on_message
+            self.client.connect_async(host, port, 30)
+            self.client.loop_start()
 
         self.th1 = threading.Thread(target=rabbit_camera_model).start()
         self.th2 = threading.Thread(target=rabbit_ai_task).start()
@@ -352,12 +354,13 @@ def video_analysis(data):
     if ret['data']['humanDetect']['found'] != 0:
         uploadFile(ipcSN, dirName, imageName, downloadDir)
     # pub msg
-    mc = mqtt.Client((MQTT_CID + '-pub') if MQTT_CID else "vamqtt-pub")
-    if MQTT_USER and MQTT_PASSWORD:
-        mc.username_pw_set(username=MQTT_USER,password=MQTT_PASSWORD)
-    mc.connect(MQTT_HOST, MQTT_PORT)
-    mc.publish('video.ai/v1.0/result', json.dumps(ret), qos=1)
-    print("mqtt message published")
+    if MQTT_HOST:
+        mc = mqtt.Client((MQTT_CID + '-pub') if MQTT_CID else "vamqtt-pub")
+        if MQTT_USER and MQTT_PASSWORD:
+            mc.username_pw_set(username=MQTT_USER,password=MQTT_PASSWORD)
+        mc.connect(MQTT_HOST, MQTT_PORT)
+        mc.publish('video.ai/v1.0/result', json.dumps(ret), qos=1)
+        print("mqtt message published")
     # rabbitmq
     if RABBITMQ_URI:
         parameters = pika.URLParameters(RABBITMQ_URI)