diff --git a/cmd/report_server/main.go b/cmd/report_server/main.go index da5a4a2..cfad9d6 100644 --- a/cmd/report_server/main.go +++ b/cmd/report_server/main.go @@ -73,7 +73,7 @@ func main() { } } }() - go sinker.ClearDimsCacheByTime(time.Minute * 30) + go sinker.ClearDimsCacheByTimeBylocal(time.Second * 20) router := fasthttprouter.New() diff --git a/platform-basic-libs/sinker/clickhouse.go b/platform-basic-libs/sinker/clickhouse.go index 0a727f1..52a3e83 100644 --- a/platform-basic-libs/sinker/clickhouse.go +++ b/platform-basic-libs/sinker/clickhouse.go @@ -54,6 +54,19 @@ func ClearDimsCacheByTime(clearTime time.Duration){ } } +func ClearDimsCacheByTimeBylocal(clearTime time.Duration){ + + for{ + time.Sleep(clearTime) + dimsCacheMap.Range(func(key, value interface{}) bool { + ClearDimsCacheByRedis(key.(string)) + dimsCacheMap.Delete(key) + return true + }) + + } +} + func ClearDimsCacheByRedis(key string){ redisConn := db.RedisPool.Get() defer redisConn.Close()