From c0ee570422fdc763303b05883d57a118cf2e32f7 Mon Sep 17 00:00:00 2001 From: "1340691923@qq.com" <1340691923@qq.com> Date: Thu, 3 Mar 2022 19:18:01 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cmd/report_server/main.go | 2 +- platform-basic-libs/sinker/clickhouse.go | 13 +++++++++++++ 2 files changed, 14 insertions(+), 1 deletion(-) 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()