Update run.py

dvr/ffmpeg/run.py

 import json, os, socket, time, datetime, pytz, subprocess as SP
 from paho.mqtt.client import Client as MQTT
 
-def TryConnect(host, port):
+def TryConnect(tag, host, port):
     now = datetime.datetime.now(tz=pytz.timezone('Asia/Taipei'))
     
     now = now.strftime('%Y/%m/%d %H:%M:%S')
@@ -12,11 +12,13 @@ def TryConnect(host, port):
         
         s.shutdown(socket.SHUT_RDWR)
         
+        print("[{0}][{1}][{2}:{3}]: Connected".format(now, tag, host, port))
+        
         return True
     except ConnectionRefusedError:
-        print("[{0}][Connect][{1}:{2}]: is refused".format(now, host, port))
+        print("[{0}][{1}][{2}:{3}]: Connection Refused Error".format(now, tag, host, port))
     except:
-        print("[{0}][Connect][{1}:{2}]: unknown error".format(now, host, port))
+        print("[{0}][{1}][{2}:{3}]: Unknown Error".format(now, tag, host, port))
     return False
     
 user = os.getenv("DVR_USER")
@@ -38,8 +40,6 @@ while True:
 
     port = os.getenv("MQTT_PORT")
     
-    print("Connect to MQTT")
-    
     if TryConnect(host, port): # 測試連線到 MQTT
         client = MQTT()
 
@@ -115,6 +115,4 @@ while True:
             
             payload['msg'] =  "Connect to EasyDarwin is refused."
 
-            client.publish(topic, json.dumps(payload), 1)
-    else:
-        print("Connect to MQTT is refused.")
\ No newline at end of file
+            client.publish(topic, json.dumps(payload), 1)
\ No newline at end of file