From a21a4236242340a4724870719c4ad7e428e53c83 Mon Sep 17 00:00:00 2001 From: douxu Date: Fri, 5 Dec 2025 17:12:14 +0800 Subject: [PATCH] optimize func of measurement data injection --- .../measurments-recommend/measurement_injection.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/deploy/redis-test-data/measurments-recommend/measurement_injection.go b/deploy/redis-test-data/measurments-recommend/measurement_injection.go index f77828e..fd756c7 100644 --- a/deploy/redis-test-data/measurments-recommend/measurement_injection.go +++ b/deploy/redis-test-data/measurments-recommend/measurement_injection.go @@ -49,8 +49,7 @@ var configMetrics = []any{ "stable", "bay", "craft", "integrity", "behavior", } -// BulkInsertAllHierarchySets 是主入口函数，用于协调所有 Set 插入操作。 -func BulkInsertAllHierarchySets(ctx context.Context, rdb *redis.Client) error { +func bulkInsertAllHierarchySets(ctx context.Context, rdb *redis.Client) error { log.Println("starting bulk insertion of Redis hierarchy sets") if err := insertStaticSets(ctx, rdb); err != nil { @@ -205,8 +204,7 @@ func insertDynamicHierarchy(ctx context.Context, rdb *redis.Client) error { } func insertAllHierarchySuggestions(ac *redisearch.Autocompleter) error { - suggestions := make([]redisearch.Suggestion, 0, 10000) // 预估容量：~2430 (Metric) + ~1100 (Path Prefixes) - + suggestions := make([]redisearch.Suggestion, 0, 10000) // S: grid Index (1-3) for S := 1; S <= 3; S++ { gridStr := fmt.Sprintf("grid%d", S) @@ -326,7 +324,7 @@ func main() { log.Fatalf("error delete exist set before bulk insertion: %v", err) } - if err := BulkInsertAllHierarchySets(ctx, rdb); err != nil { + if err := bulkInsertAllHierarchySets(ctx, rdb); err != nil { log.Fatalf("error during bulk insertion: %v", err) } }