You need to enable JavaScript to run this app.
导航

安装与client初始化

最近更新时间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)