配置環境變量
配置環境變量ALIBABA_CLOUD_ACCESS_KEY_ID和ALIBABA_CLOUD_ACCESS_KEY_SECRET。
重要
阿里云賬號AccessKey擁有所有API的訪問權限,建議您使用RAM用戶進行API訪問或日常運維,具體操作,請參見創建RAM用戶。
創建AccessKey ID和AccessKey Secret,請參考創建AccessKey。
如果您使用的是RAM用戶的AccessKey,請確保主賬號已授權AliyunServiceRoleForOpenSearch服務關聯角色,請參考OpenSearch-行業算法版服務關聯角色,相關文檔參考訪問鑒權規則。
請不要將AccessKey ID和AccessKey Secret保存到工程代碼里,否則可能導致AccessKey泄露,威脅您賬號下所有資源的安全。
Linux和macOS系統配置方法:
執行以下命令,其中,
<access_key_id>
需替換為您RAM用戶的AccessKey ID,<access_key_secret>
替換為您RAM用戶的AccessKey Secret。export ALIBABA_CLOUD_ACCESS_KEY_ID=<access_key_id> export ALIBABA_CLOUD_ACCESS_KEY_SECRET=<access_key_secret>
Windows系統配置方法
新建環境變量文件,添加環境變量ALIBABA_CLOUD_ACCESS_KEY_ID和ALIBABA_CLOUD_ACCESS_KEY_SECRET,并寫入已準備好的AccessKey ID和AccessKey Secret。
重啟Windows系統生效。
V4.0.0 SDK搜索文檔樣例代碼
搜索報錯判斷:用戶需按code和message,進行異常情況判斷,不要按status進行判斷。
code對應的錯誤信息查看——錯誤碼文檔。
SDK樣例Demo:
package com.aliyun.opensearch;
import com.aliyun.opensearch.sdk.dependencies.com.google.common.collect.Lists;
import com.aliyun.opensearch.sdk.dependencies.org.json.JSONObject;
import com.aliyun.opensearch.sdk.generated.OpenSearch;
import com.aliyun.opensearch.sdk.generated.commons.OpenSearchClientException;
import com.aliyun.opensearch.sdk.generated.commons.OpenSearchException;
import com.aliyun.opensearch.sdk.generated.search.*;
import com.aliyun.opensearch.sdk.generated.search.general.SearchResult;
import com.aliyun.opensearch.search.SearchParamsBuilder;
import com.aliyun.opensearch.search.SearchResultDebug;
import java.nio.charset.Charset;
public class testSearch {
private static String appName = "替換為opensearch應用名";
private static String host = "替換應用的API訪問地址";
public static void main(String[] args) {
//用戶識別信息
//從環境變量讀取配置的AccessKey ID和AccessKey Secret,運行代碼示例前必須先配置環境變量
String accesskey = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
String secret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
//查看文件和默認編碼格式
System.out.println(
String.format("file.encoding: %s", System.getProperty("file.encoding"))
);
System.out.println(
String.format("defaultCharset: %s", Charset.defaultCharset().name())
);
//創建并構造OpenSearch對象
OpenSearch openSearch = new OpenSearch(accesskey, secret, host);
//創建OpenSearchClient對象,并以OpenSearch對象作為構造參數
OpenSearchClient serviceClient = new OpenSearchClient(openSearch);
//創建SearcherClient對象,并以OpenSearchClient對象作為構造參數
SearcherClient searcherClient = new SearcherClient(serviceClient);
//定義Config對象,用于設定config子句參數,分頁或數據返回格式,指定應用名等等
Config config = new Config(Lists.newArrayList(appName));
config.setStart(0);
config.setHits(5);
//設置返回格式為FULLJSON,目前支持返回 XML,JSON,FULLJSON 等格式
config.setSearchFormat(SearchFormat.FULLJSON);
// 設置搜索結果返回應用中哪些字段
config.setFetchFields(
Lists.newArrayList(
"id",
"name",
"phone",
"int_arr",
"literal_arr",
"float_arr",
"cate_id"
)
);
// 注意:config子句中的rerank_size參數,在Rank類對象中設置
//設置Kvpairs子句參數,此處為distinct子句添加uniq插件,用于reserverd=false時,total及viewtotal不準確問題
//config.setKvpairs("duniqfield:cate_id");
// 創建參數對象
SearchParams searchParams = new SearchParams(config);
// 設置查詢子句,若需多個索引組合查詢,需要setQuery處合并(如下示例,可以用OR拼接),否則若設置多個setQuery后面的會替換前面查詢
searchParams.setQuery("name:'opensearch' OR title:'opensearch'");
// 設置聚合打散子句
Distinct dist = new Distinct();
dist.setKey("cate_id"); //設置dist_key
dist.setDistCount(1); //設置dist_count
dist.setDistTimes(1); //設置dist_times
dist.setReserved(false); //設置reserved
dist.setUpdateTotalHit(false); //設置update_total_hit
dist.setDistFilter("cate_id<=3"); //設置過濾條件
dist.setGrade("1.2"); //設置grade
//此處duniqfield參數通過在config子句中指定kvpairs子句形式添加
//添加Distinct對象參數
searchParams.addToDistincts(dist);
//設置統計子句
Aggregate agg = new Aggregate();
agg.setGroupKey("cate_id"); //設置group_key
agg.setAggFun("count()"); //設置agg_fun
agg.setAggFilter("cate_id=1"); //設置agg_filter
agg.setRange("0~10"); //設置分段統計
agg.setAggSamplerThresHold("5"); //設置采樣閾值
agg.setAggSamplerStep("5"); //設置采樣步長
agg.setMaxGroup("5"); //設置最大返回組數
//添加Aggregate對象參數
//searchParams.addToAggregates(agg);
//設置多個統計字段示例
Set<Aggregate> Aggregates = new HashSet();
Aggregate aggregate1 = new Aggregate();
aggregate1.setGroupKey("cate_id");
aggregate1.setAggFun("count()");
Aggregates.add(aggregate1);
Aggregate aggregate2 = new Aggregate();
aggregate2.setGroupKey("cate_id_1");
aggregate2.setAggFun("count()");
Aggregates.add(aggregate2);
searchParams.setAggregates(Aggregates);
// 設置biz參數
Map hashMap = new HashMap();
hashMap.put("biz", "type:web");
searchParams.setCustomParam(hashMap);
// 設置查詢過濾條件
// searchParams.setFilter("id > \"0\""); //此處也可改用后面的ParamsBuilder實現添加過濾條件
// 設置sort條件
Sort sorter = new Sort();
sorter.addToSortFields(new SortField("id", Order.DECREASE)); //設置id字段降序
sorter.addToSortFields(new SortField("RANK", Order.INCREASE)); //若id相同則以RANK升序
// sort中使用tag_match的用法示例:(config子句需要設置Kvpairs)
//sorter.addToSortFields(new SortField("tag_match(\"kk1\",int_array,10,\"max\",\"false\",\"false\")", Order.INCREASE));
//config.setKvpairs("kk1:10");
//添加Sort對象參數
searchParams.setSort(sorter);
// 設置粗精排表達式,此處設置為默認
Rank rank = new Rank();
rank.setFirstRankName("default");
rank.setSecondRankName("default");
rank.setReRankSize(5); //設置參與精排文檔個數
//添加Aggregate對象參數
searchParams.setRank(rank);
//設置 re_search 重查參數
//strategy:threshold,params:total_hits#10 => 這里面 strategy:threshold 表示策略,目前只支持一種策略。
//threshold 的參數是total_hits,表示第一次請求的total_hits小于這個值時觸發重查。
Map<String, String> reSearchParams = new HashMap<String, String>();
reSearchParams.put("re_search", "strategy:threshold,params:total_hits#10");
//設置下拉提示關聯搜索請求的from_request_id
reSearchParams.put("from_request_id", "159851481919726888064081");
//searchParams.setCustomParam(reSearchParams);
// 設置搜索結果摘要信息,此處采用下面的SearchParamsBuilder對象添加搜索結果摘要,比較簡便
Summary summ = new Summary("name");
summ.setSummary_field("name"); //指定的生效的字段。此字段必需為可分詞的text類型的字段。
summ.setSummary_len("50"); //片段長度
summ.setSummary_element("em"); //飄紅標簽
summ.setSummary_ellipsis("..."); //片段鏈接符
summ.setSummary_snippet("1"); //片段數量
//添加Summary對象參數
//searchParams.addToSummaries(summ);
//添加raw_query參數(參數值需要和query查詢詞保持一致)
searchParams.setRawQuery("opensearch");
// SearchParams的工具類,提供了更為便捷的操作
SearchParamsBuilder paramsBuilder = SearchParamsBuilder.create(
searchParams
);
// 使用SearchParamsBuilder對象添加搜索結果摘要
paramsBuilder.addSummary("name", 50, "em", "...", 1);
// 設置查詢過濾條件
paramsBuilder.addFilter("id>=0", "AND");
// 設置disable參數,關閉重查功能:
//searchParams.putToCustomParam("disable", "re_search");
try {
// 執行返回查詢結果。用戶需按code和message,進行異常情況判斷。code對應的錯誤信息查看——錯誤碼文檔。
SearchResult searchResult = searcherClient.execute(paramsBuilder);
String result = searchResult.getResult();
JSONObject obj = new JSONObject(result);
// 輸出查詢結果
System.out.println(obj.toString());
//個別用戶可能需要debug請求地址信息
SearchResultDebug searchdebugrst = searcherClient.executeDebug(
searchParams
);
//輸出上次查詢請求串信息
System.out.println(searchdebugrst.getRequestUrl());
} catch (OpenSearchException e) {
e.printStackTrace();
} catch (OpenSearchClientException e) {
e.printStackTrace();
}
}
}
說明
相關查詢子句參考:子句說明
文檔內容是否對您有幫助?