配置環境變量
配置環境變量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 Scroll迭代方式搜索文檔樣例代碼
該Scroll迭代方式,省去了反復設置scrollID的操作。(
scroll查詢方法,目前不支持Aggregate,Distinct,Rank子句,僅支持單字段sort.
)搜索報錯判斷:用戶需按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.generated.OpenSearch;
import com.aliyun.opensearch.sdk.generated.search.*;
import com.aliyun.opensearch.search.DeepPageingIterator;
import java.nio.charset.Charset;
public class testScrollIterator {
//Scroll不支持Aggregate,Distinct,Rank子句;支持單字段sort
private static String appName = "替換為opensearch應用名";
private static String tableName = "替換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(start) scroll該參數不起作用,默認為0
config.setHits(5);//設置每頁為5條記錄
//設置返回格式為FULLJSON,目前scroll只支持返回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類對象中設置
// 創建參數對象
SearchParams searchParams = new SearchParams(config);
// 設置查詢子句,若需多個索引組合查詢,需要setQuery處合并,否則若設置多個setQuery后面的會替換前面查詢
searchParams.setQuery("name:'opensearch'");
// 設置查詢過濾條件
//searchParams.setFilter("cate_id<=3"); //此處也可改用后面的ParamsBuilder實現添加過濾條件
// 設置sort條件
Sort sorter = new Sort();
sorter.addToSortFields(new SortField("id", Order.DECREASE)); //設置id字段降序
//添加Sort對象參數
searchParams.setSort(sorter);
//設置scroll方式查詢
DeepPaging deep =new DeepPaging();
//添加DeepPaging對象參數
searchParams.setDeepPaging(deep);
//使用DeepPageingIterator迭代操作起來會方便很多,可以不用管scroll_id之類的東西.
DeepPageingIterator pagesIterator = new DeepPageingIterator(searcherClient, searchParams);
//迭代器默認的迭代間隔是100毫秒. 此設計是為防止翻頁速度太快對我們這邊造成壓力. 當然可以改變這個迭代間隔,如下所示.
//pagesIterator.setPagingIntervals(80);//單位:ms
//用戶需按errors中的code和message進行異常情況判斷,不要按status進行判斷。code對應的錯誤信息查看——錯誤碼文檔。
try{
System.out.println("test");
while (pagesIterator.hasNext()) {
System.out.println("調試信息輸出:"+pagesIterator.next());
}
}catch(Exception ex){
System.out.println("調試報錯信息:"+ex.getMessage());
}
}
}