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

缩短访问日志自动清理时间（从每12个小时改成每6个小时）

Browse Source
This commit is contained in:
GoEdgeLab
2022-12-03 21:51:55 +08:00
parent d0f04c01c4
commit e4f06d34c3
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
internal/tasks/server_access_log_cleaner.go
View File

@@ -16,7 +16,7 @@ import (
func init() { func init() {
dbs.OnReadyDone(func() { dbs.OnReadyDone(func() {
goman.New(func() { goman.New(func() {
NewServerAccessLogCleaner(12 * time.Hour).Start() NewServerAccessLogCleaner(6 * time.Hour).Start()
}) })
}) })
} }
@@ -52,7 +52,7 @@ func (this *ServerAccessLogCleaner) Loop() error {
if len(configJSON) == 0 { if len(configJSON) == 0 {
return nil return nil
} }
config := &systemconfigs.DatabaseConfig{} var config = &systemconfigs.DatabaseConfig{}
err = json.Unmarshal(configJSON, config) err = json.Unmarshal(configJSON, config)
if err != nil { if err != nil {
return err return err
@@ -60,8 +60,8 @@ func (this *ServerAccessLogCleaner) Loop() error {
if config.ServerAccessLog.Clean.Days <= 0 { if config.ServerAccessLog.Clean.Days <= 0 {
return nil return nil
} }
days := config.ServerAccessLog.Clean.Days var days = config.ServerAccessLog.Clean.Days
endDay := timeutil.Format("Ymd", time.Now().AddDate(0, 0, -days+1)) var endDay = timeutil.Format("Ymd", time.Now().AddDate(0, 0, -days+1))
// 当前连接的数据库 // 当前连接的数据库
db, err := dbs.Default() db, err := dbs.Default()
@@ -113,7 +113,7 @@ func (this *ServerAccessLogCleaner) cleanDB(db *dbs.DB, endDay string) error {
if len(columnNames) != 1 { if len(columnNames) != 1 {
return errors.New("invalid column names: " + strings.Join(columnNames, ", ")) return errors.New("invalid column names: " + strings.Join(columnNames, ", "))
} }
columnName := columnNames[0] var columnName = columnNames[0]
var reg = regexp.MustCompile(`^(?i)(edgeHTTPAccessLogs|edgeNSAccessLogs)_(\d{8})(_\d{4})?$`) var reg = regexp.MustCompile(`^(?i)(edgeHTTPAccessLogs|edgeNSAccessLogs)_(\d{8})(_\d{4})?$`)
for _, one := range ones { for _, one := range ones {
var tableName = one.GetString(columnName) var tableName = one.GetString(columnName)