diff --git a/internal/db/models/node_value_dao.go b/internal/db/models/node_value_dao.go index c84b62fa..2c9ec20c 100644 --- a/internal/db/models/node_value_dao.go +++ b/internal/db/models/node_value_dao.go @@ -55,10 +55,10 @@ func (this *NodeValueDAO) CreateValue(tx *dbs.Tx, clusterId int64, role nodeconf }) } -// DeleteExpiredValues 清除数据 -func (this *NodeValueDAO) DeleteExpiredValues(tx *dbs.Tx) error { +// Clean 清除数据 +func (this *NodeValueDAO) Clean(tx *dbs.Tx) error { // 删除N天之前的所有数据 - expiredDays := 7 + expiredDays := 2 day := timeutil.Format("Ymd", time.Now().AddDate(0, 0, -expiredDays)) _, err := this.Query(tx). Where("day<:day"). diff --git a/internal/tasks/monitor_item_value_task.go b/internal/tasks/monitor_item_value_task.go index 62fbcbb1..74d1c0fd 100644 --- a/internal/tasks/monitor_item_value_task.go +++ b/internal/tasks/monitor_item_value_task.go @@ -39,5 +39,5 @@ func (this *MonitorItemValueTask) Start() { } func (this *MonitorItemValueTask) Loop() error { - return models.SharedNodeValueDAO.DeleteExpiredValues(nil) + return models.SharedNodeValueDAO.Clean(nil) }