diff --git a/agent/app/repo/monitor.go b/agent/app/repo/monitor.go index 64d9c0ec6..953a9cb2c 100644 --- a/agent/app/repo/monitor.go +++ b/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 diff --git a/agent/app/service/monitor.go b/agent/app/service/monitor.go index 041c893c3..c8f07fab7 100644 --- a/agent/app/service/monitor.go +++ b/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 } }