feature(user_group): support cdp cohort handler and user group experi…

…ment
volcengine · Jun 3, 2024 · a1af6f7 · a1af6f7
1 parent beec3a4
commit a1af6f7
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/cohort/cdp_client.go b/cohort/cdp_client.go
@@ -29,7 +29,13 @@ func (c *CdpClient) UseCohort(decisionId string, cohortIds []string) []string {
 	// gen req
 	var cohortIdStrBuilder strings.Builder
 	cohortIdStrBuilder.WriteString(cohortIds[0])
+	cohortIdMap := make(map[string]bool)
+	cohortIdMap[cohortIds[0]] = true
 	for _, id := range cohortIds[1:] {
+		if cohortIdMap[id] { // 去重
+			continue
+		}
+		cohortIdMap[id] = true
 		cohortIdStrBuilder.WriteString(",")
 		cohortIdStrBuilder.WriteString(id)
 	}

diff --git a/meta/manager/dynamic_meta_manager.go b/meta/manager/dynamic_meta_manager.go
@@ -90,6 +90,7 @@ func NewDynamicMetaManager(token string, options ...MetaOptionFunc) *DynamicMeta
 	}
 	if err := d.fetchMeta(); err != nil {
 		log.WithFields(log.Fields{"url": d.fetchUrl, "err": err}).Error("fetch meta err")
+		return &d
 	}
 	d.startFetcher()
 	return &d