fix: Fix lock issue during monitoring input insertion

Author: ssongliu

agent/app/repo/monitor.go

@@ -73,13 +73,28 @@ func (u *MonitorRepo) CreateMonitorBase(model model.MonitorBase) error {
 	return global.MonitorDB.Create(&model).Error
 }
 func (s *MonitorRepo) BatchCreateMonitorGPU(list []model.MonitorGPU) error {
-	return global.GPUMonitorDB.CreateInBatches(&list, len(list)).Error
+	for _, item := range list {
+		if err := global.GPUMonitorDB.Create(&item).Error; err != nil {
+			global.LOG.Errorf("create Monitor GPU record failed, err: %v", err)
+		}
+	}
+	return nil
 }
-func (u *MonitorRepo) BatchCreateMonitorIO(ioList []model.MonitorIO) error {
-	return global.MonitorDB.CreateInBatches(ioList, len(ioList)).Error
+func (u *MonitorRepo) BatchCreateMonitorIO(list []model.MonitorIO) error {
+	for _, item := range list {
+		if err := global.MonitorDB.Create(&item).Error; err != nil {
+			global.LOG.Errorf("create Monitor IO record failed, err: %v", err)
+		}
+	}
+	return nil
 }
-func (u *MonitorRepo) BatchCreateMonitorNet(ioList []model.MonitorNetwork) error {
-	return global.MonitorDB.CreateInBatches(ioList, len(ioList)).Error
+func (u *MonitorRepo) BatchCreateMonitorNet(list []model.MonitorNetwork) error {
+	for _, item := range list {
+		if err := global.MonitorDB.Create(&item).Error; err != nil {
+			global.LOG.Errorf("create Monitor Network record failed, err: %v", err)
+		}
+	}
+	return nil
 }
 func (u *MonitorRepo) DelMonitorBase(timeForDelete time.Time) error {
 	return global.MonitorDB.Where("created_at < ?", timeForDelete).Delete(&model.MonitorBase{}).Error

agent/app/service/monitor.go

@@ -414,9 +414,7 @@ func (m *MonitorService) saveIODataToDB(ctx context.Context, interval float64) {
 						}
 					}
 				}
-				if err := monitorRepo.BatchCreateMonitorIO(ioList); err != nil {
-					global.LOG.Errorf("Insert io monitoring data failed, err: %v", err)
-				}
+				_ = monitorRepo.BatchCreateMonitorIO(ioList)
 				m.DiskIO <- ioStat2
 			}
 		}
@@ -453,9 +451,7 @@ func (m *MonitorService) saveNetDataToDB(ctx context.Context, interval float64)
 					}
 				}
 
-				if err := monitorRepo.BatchCreateMonitorNet(netList); err != nil {
-					global.LOG.Errorf("Insert network monitoring data failed, err: %v", err)
-				}
+				_ = monitorRepo.BatchCreateMonitorNet(netList)
 				m.NetIO <- netStat2
 			}
 		}