Update infra_as_service_monitor.py

infra_as_service_monitor.py

@@ -43,7 +43,7 @@ restart_status_mail = config.getboolean("service", "include_restart_status")
 restart_max_count = config.getint("service", "restart_max_count")
 meta_file_path = config.get("kafka", "meta_file_path")
 meta_file_name = config.get("kafka", "meta_file_name")
-resent_time = config.get("mail_configure", "resent_time")
+resent_time = float(config.get("mail_configure", "resent_time"))
 telegram = config.get("telegram", "enable_alerts")
 mqtt = config.get("mqtt", "mqtt_enable")
 mqtt_broker = config.get("mqtt", "mqtt_broker")
@@ -187,6 +187,7 @@ def docker_container():
             for each in container_list:
                 try:
                     container = docker_client.containers.get(each)
+                    container_id = str(container.id)[0:8]
                 except docker.errors.NotFound as exc:
                     print(f"Check container name!\n{exc.explanation}")
                 else:
@@ -196,7 +197,7 @@ def docker_container():
                         end_date = datetime.datetime.now(tz=datetime.timezone.utc)
                         calculated_time = (end_date.astimezone(datetime.timezone.utc) - start_date.astimezone(
                             datetime.timezone.utc)).total_seconds()
-                        container_id = str(container.id)[0:8]
+                        
                         if container_id not in df["Services"].values:
                             df.loc[len(df.index)] = [container_id, datetime.datetime.now(), 0]
                             df.to_csv("check_time.csv")
@@ -253,12 +254,14 @@ def docker_container():
                             timing = str(round(calculated_time)) + " Minutes ago"
                         else:
                             timing = str(round(calculated_time)) + " Minutes ago"
-                    data.append([container.name, container.id, container.attrs["State"]["Status"], timing])
+                    data.append([container.name, container_id, container.attrs["State"]["Status"], timing])
 
 
         else:
             containers = docker_client.containers.list(all=True)
+            
             for each in containers:
+                container_id = str(each.id)[0:8]
                 if each.attrs["State"]["Status"] == "restarting" or each.attrs["State"]["Status"] == "exited":
 
                     end = each.attrs["State"]["FinishedAt"]
@@ -266,7 +269,6 @@ def docker_container():
                     end_date = datetime.datetime.now(tz=datetime.timezone.utc)
                     calculated_time = (end_date.astimezone(datetime.timezone.utc) - start_date.astimezone(
                         datetime.timezone.utc)).total_seconds()
-                    container_id=str(each.id)[0:8]
                     if container_id not in df["Services"].values:
                         df.loc[len(df.index)] = [container_id,datetime.datetime.now(),0]
                         df.to_csv("check_time.csv")
@@ -325,7 +327,7 @@ def docker_container():
                         timing = str(round(calculated_time)) + " Minutes ago"
                     else:
                         timing = str(round(calculated_time)) + " Minutes ago"
-                data.append([each.name, each.id, each.attrs["State"]["Status"], timing])
+                data.append([each.name, container_id, each.attrs["State"]["Status"], timing])
     except Exception as e:
         logger.info(e)