TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-15 17:40:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

缩短各项统计清理时间

Browse Source
This commit is contained in:
刘祥超
2021-12-08 10:30:14 +08:00
parent 1b8600e04d
commit 63316b6b23
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/db/models/nameservers/ns_record_hourly_stat_dao.go
View File

@@ -21,7 +21,7 @@ func init() {
var ticker = time.NewTicker(time.Duration(rands.Int(24, 48)) * time.Hour) var ticker = time.NewTicker(time.Duration(rands.Int(24, 48)) * time.Hour)
go func() { go func() {
for range ticker.C { for range ticker.C {
err := SharedNSRecordHourlyStatDAO.Clean(nil, 60) // 只保留60天 err := SharedNSRecordHourlyStatDAO.Clean(nil, 30) // 只保留N天
if err != nil { if err != nil {
remotelogs.Error("NodeClusterTrafficDailyStatDAO", "clean expired data failed: "+err.Error()) remotelogs.Error("NodeClusterTrafficDailyStatDAO", "clean expired data failed: "+err.Error())
} }

2
internal/db/models/node_value_dao.go
View File

@@ -61,7 +61,7 @@ func (this *NodeValueDAO) Clean(tx *dbs.Tx) error {
expiredDays := 2 expiredDays := 2
day := timeutil.Format("Ymd", time.Now().AddDate(0, 0, -expiredDays)) day := timeutil.Format("Ymd", time.Now().AddDate(0, 0, -expiredDays))
_, err := this.Query(tx). _, err := this.Query(tx).
Where("day<:day"). Where("day<=:day").
Param("day", day). Param("day", day).
Delete() Delete()
if err != nil { if err != nil {

2
internal/db/models/server_daily_stat_dao.go
View File

@@ -23,7 +23,7 @@ func init() {
var ticker = time.NewTicker(time.Duration(rands.Int(24, 48)) * time.Hour) var ticker = time.NewTicker(time.Duration(rands.Int(24, 48)) * time.Hour)
go func() { go func() {
for range ticker.C { for range ticker.C {
err := SharedServerDailyStatDAO.Clean(nil, 60) // 只保留60天 err := SharedServerDailyStatDAO.Clean(nil, 30) // 只保留N天
if err != nil { if err != nil {
logs.Println("ServerDailyStatDAO", "clean expired data failed: "+err.Error()) logs.Println("ServerDailyStatDAO", "clean expired data failed: "+err.Error())
} }

2
internal/setup/sql.go
View File

File diff suppressed because one or more lines are too long