最近更新时间:2022.09.14 16:00:27
首次发布时间:2022.04.13 17:53:20
推荐使用go mod来管理依赖,在go项目根目录下安装使用sdk所需的依赖文件,下载最新的sdk即可。
SDK源码地址:https://github.com/volcengine/volcengine-sdk-go-rec,支持go1.13及其以上版本。
推荐使用go mod来管理依赖,在go项目根目录下安装使用sdk所需的依赖文件,下载最新的sdk即可。
go get github.com/volcengine/volcengine-sdk-go-rec@latest
构建client,示例:
package main import ( "github.com/volcengine/volcengine-sdk-go-rec/byteair" "github.com/volcengine/volcengine-sdk-go-rec/core" "github.com/volcengine/volcengine-sdk-go-rec/core/metrics" ) var client byteair.Client func init() { client, _ = (&byteair.ClientBuilder{}). // 必传,租户id. TenantId("xxx"). // 必传,应用id. ApplicationId("xxx"). // 必传,密钥AK,获取方式:【火山引擎控制台】->【个人信息】->【密钥管理】中获取. AK("xxx"). // 必传,密钥SK,获取方式:【火山引擎控制台】->【个人信息】->【密钥管理】中获取. SK("xxx"). // 必传,国内使用RegionAirCn. Region(core.RegionAirCn). Build() // metrics上报初始化.建议开启,方便火山侧排查问题. metrics.Init() // 默认log级别为warn.根据需要自行更改. logs.Level = logs.LevelInfo }
初始化完成后,可以使用client进行数据同步和推荐服务的调用。client不需要重复创建,最好设置为全局变量,以免产生不必要的资源泄漏。
client封装了以下4个函数,分别用于请求数据服务的同步接口(write)和同步完成通知接口(done),推荐服务的推荐接口(predict)和下发回传接口(callback)。
WriteData(dataList []map[string]interface{}, topic string, opts ...option.Option) (*WriteResponse, error) Done(dateList []time.Time, topic string, opts ...option.Option) (*DoneResponse, error) Predict(request *PredictRequest, opts …option.Option) (*PredictResponse, error) Callback(request *CallbackRequest, opts …option.Option) (*CallbackResponse, error)