最近更新时间:2023.01.05 17:26:48
首次发布时间:2022.04.13 17:53:21
SDK源码地址:https://github.com/volcengine/volcengine-sdk-python-rec,支持Python 3 及其以上版本。pip地址:https://pypi.org/project/volcengine-sdk-rec/。
pip install volcengine-sdk-rec
构建client,示例:
import uuid from datetime import datetime from byteair import ClientBuilder, Client from byteair.protocol.volcengine_byteair_pb2 import * from core import Region, Option, NetException, BizException, metrics # 必传,租户id. TENANT_ID = "xxx" # 必传,应用id. APPLICATION_ID = "xxx" # 必传,密钥AK,获取方式:【火山引擎控制台】->【个人信息】->【密钥管理】中获取. AK = "xxx" # 必传,密钥SK,获取方式:【火山引擎控制台】->【个人信息】->【密钥管理】中获取. SK = "xxx" client: Client = ClientBuilder() \ .tenant_id(TENANT_ID) \ .application_id(APPLICATION_ID) \ .ak(AK) \ .sk(SK) \ .region(Region.AIR_CN) \ .build() # metrics上报初始化.建议开启,方便火山侧排查问题. metrics.init(())
初始化完成后,可以使用client进行数据同步和推荐服务的调用。client不需要重复创建,最好设置为全局变量,以免产生不必要的资源泄漏。
client封装了以下4个函数,分别用于请求数据服务的同步接口(write)和同步完成通知接口(done),推荐服务的推荐接口(predict)和下发回传接口(callback)。
write_data(self, data_list: list, topic: str, *opts: Option) done(self, date_list: Optional[list], topic: str, *opts: Option) predict(self, request: PredictRequest, *opts: CoreOption) callback(self, request: CallbackRequest, *opts: CoreOption)