最近更新时间:2023.09.28 10:53:11
首次发布时间:2022.04.13 17:53:20
SDK源码地址:https://github.com/volcengine/volcengine-sdk-java-rec,支持Java JDK 1.8及其以上版本。
在Java项目的pom.xml文件中加入相应的依赖项。
<dependencies> <dependency> <groupId>com.volcengine</groupId> <artifactId>volcengine-sdk-java-rec</artifactId> <version>1.2.1</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.30</version> </dependency> </dependencies> <repositories> <repository> <id>github-volcengine-repo</id> <name>The Maven Repository on Github</name> <url>https://volcengine.github.io/volcengine-sdk-java-rec/maven-repo/</url> </repository> </repositories>
构建client,示例:
import volcengine.byteair.ByteairClient; import volcengine.byteair.ByteairClientBuilder; import volcengine.core.*; import volcengine.core.metrics.MetricsCollector; public class Example { public static ByteairClient client; public static void init() { client = new ByteairClientBuilder() // 必传,租户id. .tenantId("xxx") // 必传,应用id. .applicationId("xxx") // 必传,密钥AK,获取方式:【火山引擎控制台】->【个人信息】->【密钥管理】中获取. .ak("xxx") // 必传,密钥SK,获取方式:【火山引擎控制台】->【个人信息】->【密钥管理】中获取. .sk("xxx") // 必传,国内使用AIR_CN. .region(Region.AIR_CN) // 进行构建client .build(); // metrics上报初始化.建议开启,方便火山侧排查问题. MetricsCollector.Init(); } }
初始化完成后,可以使用client进行数据同步和推荐服务的调用。client不需要重复创建,最好设置为全局变量,以免产生不必要的资源泄漏。
client封装了以下4个函数,分别用于请求数据服务的同步接口(write)和同步完成通知接口(done),推荐服务的推荐接口(predict)和下发回传接口(callback)。
WriteResponse writeData(List<Map<String, Object>> dataList, String topic, Option... opts) DoneResponse done(List dateList, String topic, Option... opts) PredictResponse predict(PredictRequest request, Option... opts) CallbackResponse callback(CallbackRequest request, Option... opts)