@datatester/node-sdk

Datatester分流Node.js SDK

使用及说明

import AbClient from '@datatester/node-sdk'
// const AbClient = require('@datatester/node-sdk').default

(async () => {
    // 在rangers应用管理中查询token信息
    const abClient = new AbClient('token')

    // 因为返回的是promise，业务使用上需要自己处理reject行为
    try {
        const conf = await abClient.activate('key', 'decisionId', 'trackId', new Map(), '')
        // 获取key版本配置
        const config = conf.val
    } catch(e) {
        console.error(e)
    }
})()

初始化参数

名词	类型	说明	备注
token	string	app级别的token, 可以在rangers控制台应用列表中查询
metaHost	string	获取meta数据服务host, 默认为AbClient.metaHost.cn
trackHost	string	上报实验曝光数据, 默认为AbClient.trackHost.cn
interval	number	元数据更新间隔时间，单位秒，默认60s
metaType	string	元数据类型, 可选值：'cdn', 'server', 'file'	对文件读取一次，不会按照interval去更新数据
metaFilePath	string	元数据文件本地路径，使用前确保应用对文件有可读权限	metaType==='file'时候才生效
enableFile	boolean	开启日志文件保存
dir	string	日志写入的文件路径, 默认为当前应用启动的根路径, 确保应用对路径有写路径	enableFile=true情况下日志写入路径，
maxSize	string	文件最大值 https://github.com/iccicci/rotating-file-stream#size
level	string	需要记录的日志等级 可选值：'console','info', 'warn', 'error'
formatter	function	对日志做自定义格式化输出	参数请参照types/plugins/logger/TLog
trackMaxNum	number	一次上报的事件量个数，可选值1-50，默认每10秒会自动上报一次，一次上报50条

接口及参数

接口类型参照types/type.d.ts

参数说明

• 入参

参数	类型	说明
interval	number	元数据获取时间间隔
experimentId	string	实验id
decisionId	string	决策ID, 分流口径, 和系统中设置的白名单数据行为一致
featureId	string	feature flag id
trackId	string	上报数据唯一标识
attributes	Map<string, any>	分流的受众数据，和系统中设置的目标受众做比对

• 返回值(TConfig)

参数	类型	说明
val	string	元数据获取时间间隔
vid	string	实验id
entity_id	string	决策ID, 分流口径, 和系统中设置的白名单数据行为一致

接口说明

接口	返回值	说明
getExperimentVariantName(experimentId: string, decisionId: string, attributes: Map<string, any>, options?: TOptions)	Promise<string>	命中分流结果名称
getExperimentVariantNameWithInpression(experimentId: string, decisionId: string, trackId: string, attributes: Map<string, any>, options?: TOptions)	Promise<string>	命中分流结果名称并曝光实验信息
getExperimentConfigs(experimentId: string, decisionId: string, attributes: Map<string, any>, options?: TOptions)	Promise<TConfig>	命中分流结果配置信息
getExperimentConfigsWithInpression(experimentId: string, decisionId: string, trackId: string, attributes: Map<string, any>, options?: TOptions)	Promise<TConfig>	命中分流结果配置信息并曝光信息
getAllExperimentConfigs(decisionId: string, attributes: Map<string, any>, options?: TOptions)	Promise<TConfig>	获取app下所有实验命中分流结果配置
verifyFeatureEnabled(featureId: string, decisionId: string, attributes: Map<string, any>, options?: TOptions)	Promise<boolean>	检验feature flag是否命中
getFeatureConfigs(featureId: string, decisionId: string, attributes: Map<string, any>, options?: TOptions)	Promise<TConfig>	feature flag 分流结果配置
getFeatureConfigsWithInpression(featureId: string, decisionId: string, trackId: string, attributes: Map<string, any>, options?: TOptions)	Promise<TConfig>	feature flag 分流结果配置并曝光信息
getAllFeatureConfigs(decisionId: string, attributes: Map<string, any>, options?: TOptions)	Promise<TConfig>	命中的所有feature flag版本信息
getEnabledFeatureIds(decisionId: string, attributes: Map<string, any>, options?: TOptions)	Promise<string[]>	获取所有命中的feature flag id
activate(variantKey: string, decisionId: string, trackId: string, attributes: Map<string, any>, defaultValue: unkown, options?: TOptions)	Promise<{val: any}>	根据key做分流，并上报实验信息; 返回逻辑：命中的实验信息 -> 命中的feature flag信息 -> 传入的默认值
close()	void	主动关闭所有元数据服务的schedule job
setInterval(interval: number)	void	动态调整获取元数据的间隔时间

不同场景使用

自定义获取元数据和实验信息曝光地址

• SaaS服务不同区域的配置

import AbClient from '@datatester/node-sdk'

// metaHost
// cn: AbClient.metaHost.cn 
// sg: AbClient.metaHost.sg
// va: AbClient.metaHost.va 

// trackHost
// cn: AbClient.trackHost.cn 
// sg: AbClient.trackHost.sg
// va: AbClient.trackHost.va 

const abSdk = new AbClient('token', {
    trackHost: AbClient.trackHost.sg
    metaHost: AbClient.metaHost.sg 
})

• 私有化服务

import AbClient from '@datatester/node-sdk'
const abSdk = new AbClient('token', {
    trackHost: '' // 可访问到的上报http接口的host
    metaHost: ''// 可访问到的获取元数据http接口的host
})

• 监听内部日志

sdk对外暴露了一个EventEmitter的实现，可以对sdk内部一些日志进行监听

// meta获取成功
abSdk.on('meta.success', data => {})
// meta获取失败
abSdk.on('meta.failure', error => {})
// ...