Update infra_as_service_monitor.py

infra_as_service_monitor.py

@@ -174,66 +174,70 @@ def restart(service_name):
 def docker_container():
     docker_client = docker.from_env()
     containers = docker_client.containers.list(all=True)
-    print(container_list)
-    if len(container_list)!=0:
-        for each in container_list:
-            print(each)
-            container = docker_client.containers.get(each)
-            print(container)
-            if container in containers:
-                print("1")
-                if container.attrs["State"]["Status"] =="restarting" or container.attrs["State"]["Status"] =="exited":
-                    print("2")
-                    container_restart.append(container)
-                    start=container.attrs["State"]["StartedAt"]
-                    end=container.attrs["State"]["FinishedAt"]
+    try:
+        print(container_list)
+        if len(container_list)!=0:
+            for each in container_list:
+                print(each)
+                container = docker_client.containers.get(each)
+                print(container)
+                if container in containers:
+                    print("1")
+                    if container.attrs["State"]["Status"] =="restarting" or container.attrs["State"]["Status"] =="exited":
+                        print("2")
+                        container_restart.append(container)
+                        start=container.attrs["State"]["StartedAt"]
+                        end=container.attrs["State"]["FinishedAt"]
+                        start_date = dateutil.parser.isoparse(start)
+                        end_date = dateutil.parser.isoparse(end)
+                        time=((end_date-start_date).total_seconds())
+                        print("3")
+                    if container.attrs["State"]["Status"] =="running" or  container.attrs["State"]["Status"] =="created":
+                        start_date = dateutil.parser.isoparse(start)
+                        end_date = datetime.datetime.now(tz=datetime.timezone.utc)
+                        time=(end_date.astimezone(datetime.timezone.utc) - start_date.astimezone(datetime.timezone.utc)).total_seconds()
+                        print("3")
+                    if time>3600:
+                        time=time/3600
+                        timing=str(int(time))+"hour"
+                        print("4")
+                    elif time<60:
+                        timing=str(int(time))+"seconds"
+                        print("4")
+                    elif time>60:
+                        time=time/60
+                        timing=str(int(time))+"minute"
+                        print("4")
+                    print(timing)
+                    data.append([container.name, container.id, container.attrs["State"]["Status"],timing])
+                    print(data)
+                    
+        else:
+            
+            for each in containers:
+                if each.attrs["State"]["Status"] =="restarting" or each.attrs["State"]["Status"] =="exited":
+                    container_restart.append(each)
+                    start=each.attrs["State"]["StartedAt"]
+                    end=each.attrs["State"]["FinishedAt"]
                     start_date = dateutil.parser.isoparse(start)
                     end_date = dateutil.parser.isoparse(end)
                     time=((end_date-start_date).total_seconds())
-                    print("3")
-                if container.attrs["State"]["Status"] =="running" or  container.attrs["State"]["Status"] =="created":
+                if each.attrs["State"]["Status"] =="running" or  each.attrs["State"]["Status"] =="created":
                     start_date = dateutil.parser.isoparse(start)
                     end_date = datetime.datetime.now(tz=datetime.timezone.utc)
                     time=(end_date.astimezone(datetime.timezone.utc) - start_date.astimezone(datetime.timezone.utc)).total_seconds()
-                    print("3")
                 if time>3600:
                     time=time/3600
                     timing=str(int(time))+"hour"
-                    print("4")
                 elif time<60:
                     timing=str(int(time))+"seconds"
-                    print("4")
                 elif time>60:
                     time=time/60
                     timing=str(int(time))+"minute"
-                    print("4")
-                print(timing)
-                data.append([container.name, container.id, container.attrs["State"]["Status"],timing])
-                print(data)
-                
-    else:
-        
-        for each in containers:
-            if each.attrs["State"]["Status"] =="restarting" or each.attrs["State"]["Status"] =="exited":
-                container_restart.append(each)
-                start=each.attrs["State"]["StartedAt"]
-                end=each.attrs["State"]["FinishedAt"]
-                start_date = dateutil.parser.isoparse(start)
-                end_date = dateutil.parser.isoparse(end)
-                time=((end_date-start_date).total_seconds())
-            if each.attrs["State"]["Status"] =="running" or  each.attrs["State"]["Status"] =="created":
-                start_date = dateutil.parser.isoparse(start)
-                end_date = datetime.datetime.now(tz=datetime.timezone.utc)
-                time=(end_date.astimezone(datetime.timezone.utc) - start_date.astimezone(datetime.timezone.utc)).total_seconds()
-            if time>3600:
-                time=time/3600
-                timing=str(int(time))+"hour"
-            elif time<60:
-                timing=str(int(time))+"seconds"
-            elif time>60:
-                time=time/60
-                timing=str(int(time))+"minute"
-            data.append([each.name, each.id, each.attrs["State"]["Status"],timing])
+                data.append([each.name, each.id, each.attrs["State"]["Status"],timing])
+    except Exception as e:
+            logger.error("Error connecting to kairos")
+