行为反馈

行为数据上报的好处

• 通过用户对结果的反馈，方便产研侧后面评估效果，优化产品体验。

• 通过行为数据的返回可以为用户提供效果的报表展示，更直观的查看对应报表数据。

上报行为数据

说明：建议通过SDK手动上传行为数据。下文详细介绍了行为数据包含的字段类型与含义。

SDK上报有8个必须字段：user_id、biz_id、trace_id、rn、item_type、bhv_type、bhv_time、reach_time。

常见行为取值

bhv_value格式

{
 "code":[2.3,2.5], # 用来设置具体的问题类型，具体code值及含义见下表
 "expect" : "期望答复的内容"
}

Push 推送采集数据

参数描述

push 代码示例：

import com.aliyun.opensearch.DataCollectionClient;
import com.aliyun.opensearch.OpenSearchClient;
import com.aliyun.opensearch.sdk.generated.OpenSearch;
import com.aliyun.opensearch.sdk.generated.commons.OpenSearchResult;
import static org.junit.Assert.assertTrue;

public class PushLLMBehavioralData {
	private static String accesskey = "your ak";
 private static String secret = "your secret";
 private static String host = "your host";
 private static String searchAppName = "app_name";
 private static String dataCollectionName = "opened_data_collection_name";
 private static String dataCollectionType = "BEHAVIOR";
 public static void main(String[] args) throws Exception {
 //创建并构造OpenSearch对象
 OpenSearch opensearch = new OpenSearch(accesskey, secret, host);
 //创建OpenSearchClient对象，并以OpenSearch对象作为构造参数
 OpenSearchClient client = new OpenSearchClient(opensearch);
 //创建DataCollectionClient对象，并以OpenSearchClient对象作为构造参数
 DataCollectionClient dataCollectionClient = new DataCollectionClient(client);
 // 直接推送文档
 String docJson = "[{\"cmd\": \"ADD\",\"fields\": {"\user_id"\:"\1120021255"\,\"biz_id\": 1365378,\"rn\": \"170107366216796189819166\",\"trace_id\": \"Alibaba\",\"item_id\": \"id\",\"item_type\": \"goods\",\"bhv_type\": \"click\",\"bhv_time\": \"1701074578\"}}]";
 try {
 OpenSearchResult openSearchResult = dataCollectionClient.push(docJson,
 searchAppName, dataCollectionName,
 dataCollectionType);
 System.out.println(openSearchResult);
 } catch (Exception e) {
 e.printStackTrace();
 assertTrue(false);
 return;
 }
 }
}

commit 代码示例：

package com.aliyun.opensearch.demo;
import com.aliyun.opensearch.DataCollectionClient;
import com.aliyun.opensearch.OpenSearchClient;
import com.aliyun.opensearch.sdk.generated.OpenSearch;
import com.aliyun.opensearch.sdk.generated.commons.OpenSearchResult;
import java.util.HashMap;
import java.util.Map;
public class PushDataCollectionDoc {
 private static String accesskey = "your ak";
 private static String secret = "your secret";
 private static String host = "your host";
 private static String searchAppName = "opensearch_app_name";
 private static String dataCollectionName = "opened_data_collection_name";
 private static String dataCollectionType = "BEHAVIOR";
 public static void main(String[] args) {
 //创建并构造OpenSearch对象
 OpenSearch opensearch = new OpenSearch(accesskey, secret, host);
 //创建OpenSearchClient对象，并以OpenSearch对象作为构造参数
 OpenSearchClient client = new OpenSearchClient(opensearch);
 //创建DataCollectionClient对象，并以OpenSearchClient对象作为构造参数
 DataCollectionClient dataCollectionClient = new DataCollectionClient(client);
 Map<String, Object> fields = new HashMap<String, Object>();
 
 // 用户唯一标识
 fields.put("user_id", "1120021255");
 // 业务侧用于区分不同业务的数值ID 对应一个开放搜索应用
 fields.put("biz_id", 1365378);
 // 搜索结果中返回的request_id的值，原样回传即可
 fields.put("rn", "1564455556323223680397827");
 // 如果是来自开放搜索的结果，该字段值设置为Alibaba
 fields.put("trace_id", "Alibaba");
 // 开放搜索应用中主表主键值
 fields.put("item_id", "2223");
 // item类型为 物品、商品
 fields.put("item_type", "goods");
 // 点击类行为数据
 fields.put("bhv_type", "click");
 // 行为发生的秒级时间戳
 fields.put("bhv_time", "1566475047");
 //增加一条文档
 //这条文档只是增加到 SDK Client buffer中，没有正式提交到服务端；只有调用了 commit 方法才会被提交到服务端。
 //可以多次调用 add，然后调用commit() 统一提交。
 dataCollectionClient.add(fields);
 try {
 OpenSearchResult openSearchResult = dataCollectionClient.commit(searchAppName, dataCollectionName, dataCollectionType);
 System.out.println(openSearchResult);
 } catch (Exception e) {
 e.printStackTrace();
 return;
 }
 }
}