数据推送 Demo

本文将介绍通过召回引擎版Java SDK客户端将数据实时同步到召回引擎版的实例中，支持的更新操作有：add、delete。

add 操作示例

package com.aliyun.ha3engine;
import com.aliyun.ha3engine.Client;
import com.aliyun.ha3engine.models.*;
import com.aliyun.tea.TeaException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;

/**
 * @author alibaba
 */
public class PushDoc {

 public static void main(String[] args) throws Exception {
 Config config = new Config();

 // API域名，可在实例详情页>API入口 查看
 config.setEndpoint("<instance_services_domain>");
 // 实例名称，可在实例详情页左上角查看，例:ha-cn-i7*****605
 config.setInstanceId("<instance_id>");

 // 用户名，可在实例详情页>网络信息 查看
 config.setAccessUserName("<user_name>");
 // 密码，可在实例详情页>网络信息 修改
 config.setAccessPassWord("<user_password>");

 Client client = new Client(config);

 // 文档推送的数据源配置名称.可在实例管理>配置中心>数据源配置 查看
 String tableName = "<instance_datasource_table_name>";

 // 文档推送的文档主键字段.
 String pkField = "<field_pk>";

 try {
 // 文档推送外层结构, 可添加对文档操作的结构体. 结构内支持一个或多个文档操作内容.
 ArrayList<Map<String, ?>> documents = new ArrayList<>();

 // 添加文档
 Map<String, Object> add2Document = new HashMap<>();
 Map<String, Object> add2DocumentFields = new HashMap<>();

 // 插入文档内容信息, keyValue 成对匹配.
 // field_pk 字段需与 pkField 字段配置一致.
 add2DocumentFields.put("<field_pk>", "<field_pk_value>");
 add2DocumentFields.put("<field_map_key_1>", "<field_map_value_1>");
 add2DocumentFields.put("<field_map_key_2>", "<field_map_value_2>");

 // 问天引擎支持的多值属性类型,索引内配置为"multi_value": true
 ArrayList<Object> addDocumentMultiFields = new ArrayList<>();
 addDocumentMultiFields.add("multi_value_1");
 addDocumentMultiFields.add("multi_value_2");
 add2DocumentFields.put("<multi_value_key>", addDocumentMultiFields);
 
 // 将文档内容添如 add2Document 结构.
 add2Document.put("fields", add2DocumentFields);
 // 新增对应的文档命令: add
 add2Document.put("cmd", "add");
 documents.add(add2Document);
 
 // 推送数据
 PushDocumentsRequestModel requestModel = new PushDocumentsRequestModel();
 requestModel.setBody(documents);
 PushDocumentsResponseModel responseModel = client.pushDocuments(tableName, pkField, requestModel);
 String responseBody = responseModel.getBody();

 System.out.println("result：" + responseBody);

 } catch (TeaException e) {
 System.out.println(e.getMessage());

 Map<String, Object> abc = e.getData();

 System.out.println(com.aliyun.teautil.Common.toJSONString(abc));
 }
 }
}

结构展示：

[
    {
        "cmd":"add",
        "fields":{
            "id":"1",
            "title":"This is the title",
            "body":"This is the body",
            "tags":[
                1,
                2,
                3
            ]
        }
    }
]

delete 操作示例

package com.aliyun.ha3engine;
import com.aliyun.ha3engine.Client;
import com.aliyun.ha3engine.models.*;
import com.aliyun.tea.TeaException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;

/**
 * @author alibaba
 */
public class PushDoc {

 public static void main(String[] args) throws Exception {
 Config config = new Config();

 // API域名，可在实例详情页>API入口 查看
 config.setEndpoint("<instance_services_domain>");
 // 实例名称，可在实例详情页左上角查看，例:ha-cn-i7*****605
 config.setInstanceId("<instance_id>");

 // 用户名，可在实例详情页>网络信息 查看
 config.setAccessUserName("<user_name>");
 // 密码，可在实例详情页>网络信息 修改
 config.setAccessPassWord("<user_password>");

 Client client = new Client(config);

 // 文档推送的数据源配置名称.可在实例管理>配置中心>数据源配置 查看
 String tableName = "<instance_datasource_table_name>";

 // 文档推送的文档主键字段.
 String pkField = "<field_pk>";

 try {
 // 文档推送外层结构, 可添加对文档操作的结构体. 结构内支持一个或多个文档操作内容.
 ArrayList<Map<String, ?>> documents = new ArrayList<>();

 // 删除文档
 Map<String, Object> delete2Document = new HashMap<>();
 Map<String, Object> delete2DocumentFields = new HashMap<>();

 // 插入文档内容信息, keyValue 成对匹配.
 // field_pk 字段需与 pkField 字段配置一致.
 delete2DocumentFields.put("<field_pk>", "<field_pk_value>");

 // 将文档内容添如 delete2Document 结构.
 delete2Document.put("fields", delete2DocumentFields);
 // 删除对应的文档命令: delete
 delete2Document.put("cmd", "delete");
 documents.add(delete2Document);

 // 推送数据
 PushDocumentsRequestModel requestModel = new PushDocumentsRequestModel();
 requestModel.setBody(documents);
 PushDocumentsResponseModel responseModel = client.pushDocuments(tableName, pkField, requestModel);
 String responseBody = responseModel.getBody();

 System.out.println("result：" + responseBody);

 } catch (TeaException e) {
 System.out.println(e.getMessage());

 Map<String, Object> abc = e.getData();

 System.out.println(com.aliyun.teautil.Common.toJSONString(abc));
 }
 }
}

结构展示：

[
    {
        "cmd":"delete",
        "fields":{
            "id":"3"
        }
    }
]