This SDK is only supported on Go v1.15 and later versions.
Obtain your project's App Key:
- Go to the BytePlus console and sign in to your account.
- Under the Products section, click BytePlus Data Intelligence.
- On the Project List page, for the project you want to integrate the SDK with, under the Actions column, click Details.
- On the Social Media Details pop-up window, copy the App Key.
go get github.com/volcengine/[email protected]
The following is a code example of using the Go SDK.
package main
import (
"github.com/volcengine/datatester-go-sdk/client"
"github.com/volcengine/datatester-go-sdk/config"
)
func main() {
// Find your app key by clicking "details" on the project list page on the BytePlus console
abClient := client.NewClient("${app_key}")
/*
client.NewClient("2b47a1f318d78fd718548153901addde",
config.WithMetaHost(config.MetaHostSG), // Change it to "https://datarangers.com"
config.WithTrackHost(config.TrackHostSG), // Change it to "https://mcs.tobsnssdk.com"
config.WithWorkerNumOnce(20)) // The number of worker threads. 20 by default. Only supports one-time configuration
config.WithFetchInterval(60 * time.Second), // meta update interval, N * time.Second is recommended
config.WithAnonymousConfig(true, true), // anonymous user event reporting configuration(enable/disable, saas/onpremise)
config.WithLogger(log.NewLogrusAdapt(logrus.New()))) // customize the log interface
*/
// attributes: User properties. Only used for allocating the traffic
attributes := map[string]interface{}{
}
// decisionId: The local user identifier. Not used for event tracking. You need to replace it with the actual user ID
// trackId(uuid): The user identifier for event tracking. You need to replace it with the actual user ID
value, err := abClient.Activate("${experiment_key}", "decisionId", "trackId", true, attributes)
if err != nil {
return
}
if value.(bool) {
} else {
}
}
Interfaces with WithImpression automatically track events. Meanwhile, make sure you fill in the trackId field in the activate interface if you want to track events.
A class for traffic allocation during initialization.
NewClient(token string, configs ...config.Func) *AbClient
| Parameter | Description | Value |
|---|---|---|
| token | Your project's App Key. You can obtain it in the Prerequisites section. | 2b47*****8d78fd718548153901addde |
| config.WithMetaHost(config.MetaHostSG) | Default value is CN SAAS, set according to business needs | |
| config.WithFetchInterval(60 * time.Second) | Meta update interval, N * time.Second is recommended or use default value | |
| config.WithTrackHost(config.TrackHostSG) | Default value is CN SAAS, set according to business needs | |
| config.WithWorkerNumOnce(20)) | The number of worker threads. 20 by default. Only supports one-time configuration | |
| config.WithAnonymousConfig(true, true) | Anonymous user event reporting configuration(enable/disable, saas/onpremise) | |
| config.WithLogger(log.NewLogrusAdapt(logrus.New()))) | The logger interface which has a default value but you can customize it. |
A class for traffic allocation during initialization.
NewClientWithUserAbInfo(token string, userAbInfoHandler handler.UserAbInfoHandler, configs ...config.Func) *AbClient
| Parameter | Description | Value |
|---|---|---|
| userAbInfoHandler | Ensure that incoming users' information about version ID remains unchanged. If you want to constantly store the information of incoming users, you must implement it by yourself |
Set a cohort handler used to obtain experiment/feature cohort ids
func (t *AbClient) SetCohortHandler(handler cohort.Client)
| Parameter | Description |
|---|---|
| handler | handler to obtain cohort ids used in experiments or features. You can use the built-in cohort handlers, or customize your own handler |
Obtain a specific experiment version's configuration after traffic allocation and automatically track the exposed events.
func (t *AbClient) Activate(variantKey, decisionId, trackId string, defaultValue interface{},
attributes map[string]interface{}) (interface{}, error)
| Parameter | Description |
|---|---|
| variantKey | The key of the experiment version |
| decisionId | The local user identifier for traffic allocating |
| trackId | The user identifier for event tracking. You need to replace it with the actual user ID |
| defaultValue | When a user/device is not in this version, then the value of this parameter is returned. You can set its value as "nil" |
| attributes | User properties |
Parameters of the version ID that a user enters or the default value when a user/device is not in this version.
Obtain the version's name of an experiment that a user enters.
func (t *AbClient) GetExperimentVariantName(experimentId, decisionId string,
attributes map[string]interface{}) (string, error)
| Parameter | Description |
|---|---|
| experimentId | The experiment ID to which traffic is allocated |
Name of the version ID that a user enters or "" when a user/device is not in this version.
Obtain detailed information about the version that a user enters.
func (t *AbClient) GetExperimentConfigs(experimentId, decisionId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
The detailed information about the version ID that a user enters or "nil" when a user/device is not in this version. The following is an example:
{
"father_code": {
"val": "father_code_2",
"vid": "12345"
}
}
Obtain detailed information about all the versions in all experiments.
func (t *AbClient) GetAllExperimentConfigs(decisionId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
The detailed information about version IDs that a user enters or "nil" when a user/device is not in this version. The following is an example:
{
"father_code": {
"val": "father_code_2",
"vid": "12345"
},
"grey_rollout": {
"val": false,
"vid": "45678"
}
}
Obtain detailed information about a feature that a user joins.
func (t *AbClient) GetFeatureConfigs(featureId, decisionId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
| Parameter | Description |
|---|---|
| featureId | The feature's identifier |
An array object of detailed information about a feature's variant that a user joins. "nil" when a user/device is not in this feature or the feature is disabled. The following is an example:
{
"feature_key":{
"val" : "prod",
"vid" : "20006421"
}
}
Obtain detailed information about all features that a user joins.
func (t *AbClient) GetAllFeatureConfigs(decisionId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
The detailed information about all feature variants that a user joins. The following is an example:
{
"feature_key":{
"val" : "prod",
"vid" : "20006421"
}
"feature_key_color":{
"val" : "true",
"vid" : "20006423"
}
}
Obtain the version's name of the experiment that a user enters.
func (t *AbClient) GetExperimentVariantNameWithImpression(experimentId, decisionId, trackId string,
attributes map[string]interface{}) (string, error)
Name of the version ID that a user enters or "" when a user/device is not in this version.
Obtain detailed information about the version that a user enters.
func (t *AbClient) GetExperimentConfigsWithImpression(experimentId, decisionId, trackId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
The detailed information about the version ID that a user enters or "nil" when a user/device is not in this version. The following is an example:
{
"father_code": {
"val": "father_code_2",
"vid": "12345"
}
}
Obtain detailed information about all the versions in all experiments.
func (t *AbClient) GetAllExperimentConfigsWithImpression(decisionId string, trackId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
The detailed information about version IDs that a user enters or "nil" when a user/device is not in this version. The following is an example:
{
"father_code": {
"val": "father_code_2",
"vid": "12345"
},
"grey_rollout": {
"val": false,
"vid": "45678"
}
}
Obtain detailed information about a feature that a user joins.
func (t *AbClient) GetFeatureConfigsWithImpression(featureId, decisionId, trackId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
The detailed information about a feature's variant that a user joins. "nil" when a user/device is not in this feature or the feature is disabled. The following is an example:
{
"feature_key":{
"val" : "prod",
"vid" : "20006421"
}
}
In order to better use the sdk, some suggestions are provided.
Maintain user historical decision information; If you need to use the function of 'freezing experiment' or 'Traffic changes will not affect exposed users', you can customize the implementation class processing, and use it in when instantiating AbClient(NewClientWithUserAbInfo).
It is recommended to use redis to cache decision information.
The following is an example:
client.NewClientWithUserAbInfo("appKey", NewRedisUserAbInfoHandler())
type RedisAbInfoHandler struct{}
func (u *RedisAbInfoHandler) Query(decisionID string) string {
// need to implement it yourself
return redis.get(decisionID);
}
func (u *RedisAbInfoHandler) CreateOrUpdate(decisionID, experiment2Variant string) bool {
// need to implement it yourself
return redis.set(decisionID, experiment2Variant);
}
func (u *RedisAbInfoHandler) NeedPersistData() bool {
// return true if customize this interface
return true
}
func NewRedisUserAbInfoHandler() *RedisAbInfoHandler {
return &RedisAbInfoHandler{}
}
Handler to obtain cohort ids if your experiment / feature uses cohorts as traffic filter. You can either use the built-in cohort handler listed below, or implement your own handler
- cdp cohort handler (built-in)
func NewCdpClient(cdpApi *cdpCli.APIClient, tenantId int64) *CdpClient
for more detail in cdp api, see https://github.com/volcengine/cdp-openapi-sdk-go
- customize cohort handler
you can customize your own cohort handler by implementing cohort.Client interface
type Client interface {
UseCohort(decisionId string, cohortIds []string) []string
}
here shows a simple example, obtain cohort from redis
type redisCohortClient struct {
}
func (c *redisCohortClient) UseCohort(decisionId string, cohortIds []string) []string {
return redis.get(decisionID);
}
If there is no uuid as trackId, you can use device_id, web_id, bddid(only onpremise) for anonymous tracking.
- init anonymous config
enable anonymously tracking
client.NewClient("appKey", config.WithAnonymousConfig(true, true))
- append device_id, web_id, bddid to attributes when trackId is empty string
trackId = "";
attributes["device_id"] = 1234; int64
attributes["web_id"] = 5678; int64
attributes["bddid"] = "91011"; string
- call activate or 'WithImpression' interfaces
Go v1.15及更高版本
获取应用的App Key（即SDK使用的token）:
- 访问火山引擎并登录您的账号
- 进入集团设置页面，找到应用列表-应用ID列
- 鼠标悬停在应用ID后的感叹号上获取App Key
go get github.com/volcengine/[email protected]
package main
import (
"github.com/volcengine/datatester-go-sdk/client"
"github.com/volcengine/datatester-go-sdk/config"
)
func main() {
abClient := client.NewClient("${app_key}")
/*
client.NewClient("2b47a1f318d78fd718548153901addde",
config.WithMetaHost(config.MetaHostCN), // 默认使用国内SAAS域名，私有化需要自行传入产品域名
config.WithTrackHost(config.TrackHostCN), // 默认使用国内SAAS域名，私有化需要自行传入上报域名
config.WithWorkerNumOnce(20)) // 事件上报协程数，一般不需要设置
config.WithFetchInterval(60 * time.Second), // meta更新间隔，默认为60s，一般不需要设置
config.WithAnonymousConfig(true, true), // 匿名上报配置，第一个参数为开启关闭，第二个参数区分saas和私有化
config.WithLogger(log.NewLogrusAdapt(logrus.New()))) // 自定义日志接口，提供默认实现
*/
// attributes: 用户属性
attributes := map[string]interface{}{
}
// decisionId: 本地分流用户标识，不用于事件上报，请替换为客户的真实用户标识
// trackId(uuid): 事件上报用户标识，用于事件上报，请替换为客户的真实用户标识
value, err := abClient.Activate("${experiment_key}", "decisionId", "trackId", true, attributes)
if err != nil {
return
}
if value.(bool) {
} else {
}
}
初始化ABTest分流类
NewClient(token string, configs ...config.Func) *AbClient
| 参数 | 描述 | 值 |
|---|---|---|
| token | 获取到的App Key | 2b47*****8d78fd71854815390 |
| config.WithMetaHost | 默认使用国内SAAS的域名，根据业务需要设置 | |
| config.WithFetchInterval(60 * time.Second) | meta更新间隔，默认为60s，一般不需要设置 | |
| config.WithTrackHost | 默认使用国内SAAS的域名，根据业务需要设置 | |
| config.WithWorkerNumOnce(20)) | 事件上报协程数，一般不需要设置 | |
| config.WithAnonymousConfig(true, true) | 匿名上报配置，第一个参数为开启关闭，第二个参数区分saas和私有化 | |
| config.WithLogger(log.NewLogrusAdapt(logrus.New()))) | 自定义日志接口，提供默认实现 |
初始化ABTest分流类，传入自定义的userAbInfoHandler
NewClientWithUserAbInfo(token string, userAbInfoHandler handler.UserAbInfoHandler, configs ...config.Func) *AbClient
| 参数 | 描述 | 值 |
|---|---|---|
| userAbInfoHandler | 用户进组信息管理接口，提供默认实现，实验冻结和进组不出组场景下需自行实现 |
设置用户分群handler
func (t *AbClient) SetCohortHandler(handler cohort.Client)
| 参数 | 描述 |
|---|---|
| handler | 用户分群handler。可以用sdk内置的cdp分群接口，也可以自行实现 |
获取特定key的分流结果，并上报曝光事件
func (t *AbClient) Activate(variantKey, decisionId, trackId string, defaultValue interface{},
attributes map[string]interface{}) (interface{}, error)
| 参数 | 描述 |
|---|---|
| variantKey | 变体的key |
| decisionId | 本地分流用户标识 |
| trackId | 事件上报用户标识 |
| defaultValue | 变体默认值 |
| attributes | 用户属性 |
该函数返回命中版本的参数值，未命中时返回默认值
获取用户命中的特定实验的变体名称
func (t *AbClient) GetExperimentVariantName(experimentId, decisionId string,
attributes map[string]interface{}) (string, error)
| 参数 | 描述 |
|---|---|
| experimentId | 指定分流的实验Id |
该函数返回用户命中的特定实验的变体名称
获取用户命中的特定实验的变体详情
func (t *AbClient) GetExperimentConfigs(experimentId, decisionId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
该函数返回用户命中某个实验的变体详情，通常仅能命中一个变体
{
"father_code": {
"val": "father_code_2",
"vid": "12345"
}
}
获取用户命中的所有实验的变体详情
func (t *AbClient) GetAllExperimentConfigs(decisionId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
该函数返回用户命中所有实验的变体详情，通常命中多个变体
{
"father_code": {
"val": "father_code_2",
"vid": "12345"
},
"grey_rollout": {
"val": false,
"vid": "45678"
}
}
获取用户命中的特定feature的变体详情
func (t *AbClient) GetFeatureConfigs(featureId, decisionId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
| 参数 | 描述 |
|---|---|
| featureId | feature Id |
该函数返回用户命中某个feature的变体详情，通常仅能命中一个变体
{
"feature_key":{
"val" : "prod",
"vid" : "20006421"
}
}
获取用户命中的所有feature的变体详情
func (t *AbClient) GetAllFeatureConfigs(decisionId string,
attributes map[string]interface{}) (map[string]map[string]interface{}, error)
该函数返回用户命中所有feature的变体详情，通常命中多个变体
{
"feature_key":{
"val" : "prod",
"vid" : "20006421"
}
"feature_key_color":{
"val" : "true",
"vid" : "20006423"
}
}
1、含有“WithImpression”字样的接口均会自动上报曝光事件
2、请务必填写trackId字段，否则会导致上报失效
同接口“getExperimentVariantName”
同接口“getExperimentConfigs”
同接口“getAllExperimentConfigs”
同接口“getFeatureConfigs”
用户信息处理接口，冻结实验、进组不出组场景下使用
- 使用NewClient初始化AbClient时默认使用空实现，不启用“进组不出组”功能
- 继承UserAbInfoHandler接口，自行实现持久化存储；使用NewClientWithUserAbInfo初始化AbClient，并传入自行实现的UserAbInfoHandler类，则可启用“进组不出组”功能
使用Redis缓存示例（仅供参考）
client.NewClientWithUserAbInfo("appKey", NewRedisUserAbInfoHandler())
type RedisAbInfoHandler struct{}
func (u *RedisAbInfoHandler) Query(decisionID string) string {
// need to implement it yourself
return redis.get(decisionID);
}
func (u *RedisAbInfoHandler) CreateOrUpdate(decisionID, experiment2Variant string) bool {
// need to implement it yourself
return redis.set(decisionID, experiment2Variant);
}
func (u *RedisAbInfoHandler) NeedPersistData() bool {
// return true if customize this interface
return true
}
func NewRedisUserAbInfoHandler() *RedisAbInfoHandler {
return &RedisAbInfoHandler{}
}
获取分群id，用于判断实验/feature的用户分群过滤条件
- cdp cohort handler (内置)
func NewCdpClient(cdpApi *cdpCli.APIClient, tenantId int64) *CdpClient
cdp api的使用可以参考 https://github.com/volcengine/cdp-openapi-sdk-go
- 自定义cohort handler
可以通过实现cohort.Client接口来自定义cohort handler的实现
type Client interface {
UseCohort(decisionId string, cohortIds []string) []string
}
通过redis获取分群的示例（仅供参考）
type redisCohortClient struct {
}
func (c *redisCohortClient) UseCohort(decisionId string, cohortIds []string) []string {
return redis.get(decisionID);
}
获取不到uuid的用户，可以通过填充device_id或者web_id进行事件上报（私有化场景下也支持bddid）
- NewClient时设置匿名上报配置，第一个参数（true/开启，false/关闭）匿名上报，第二个参数（true/saas，false/私有化）
client.NewClient("appKey", config.WithAnonymousConfig(true, true))
- 添加device_id, web_id, bddid到用户属性attributes，trackId固定传入空字符串""
trackId = "";
attributes["device_id"] = 1234; int64
attributes["web_id"] = 5678; int64
attributes["bddid"] = "91011"; string
- 请求activate或其他'WithImpression'接口即可匿名上报
