push推送帶搜索Demo
配置環(huán)境變量
配置環(huán)境變量ALIBABA_CLOUD_ACCESS_KEY_ID和ALIBABA_CLOUD_ACCESS_KEY_SECRET。
阿里云賬號AccessKey擁有所有API的訪問權(quán)限,建議您使用RAM用戶進行API訪問或日常運維,具體操作,請參見創(chuàng)建RAM用戶。
創(chuàng)建AccessKey ID和AccessKey Secret,請參考創(chuàng)建AccessKey。
如果您使用的是RAM用戶的AccessKey,請確保主賬號已授權(quán)AliyunServiceRoleForOpenSearch服務(wù)關(guān)聯(lián)角色,請參考OpenSearch-行業(yè)算法版服務(wù)關(guān)聯(lián)角色,相關(guān)文檔參考訪問鑒權(quán)規(guī)則。
請不要將AccessKey ID和AccessKey Secret保存到工程代碼里,否則可能導(dǎo)致AccessKey泄露,威脅您賬號下所有資源的安全。
Linux和macOS系統(tǒng)配置方法:
執(zhí)行以下命令,其中,
<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系統(tǒng)配置方法
新建環(huán)境變量文件,添加環(huán)境變量ALIBABA_CLOUD_ACCESS_KEY_ID和ALIBABA_CLOUD_ACCESS_KEY_SECRET,并寫入已準(zhǔn)備好的AccessKey ID和AccessKey Secret。
重啟Windows系統(tǒng)生效。
創(chuàng)建Config配置頭文件
Config 頁面中的內(nèi)容將作為后續(xù)的查詢推送文檔的頭文件,其中包含AK,host,應(yīng)用名,下拉名稱及 options 選項,等重要參數(shù)信息
$secret = getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET');<?php
//引入頭文件
require_once("../OpenSearch/Autoloader/Autoloader.php");
use OpenSearch\Client\OpenSearchClient;
// 用戶識別信息
// 從環(huán)境變量讀取配置的AccessKey ID和AccessKey Secret,
// 運行代碼示例前必須先配置環(huán)境變量,參考文檔上面“配置環(huán)境變量”步驟
// 替換對應(yīng)的access key id
$accessKeyId = getenv('ALIBABA_CLOUD_ACCESS_KEY_ID');
//替換對應(yīng)的access secret
$secret = getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET');
//替換為對應(yīng)區(qū)域api訪問地址,可參考應(yīng)用控制臺,基本信息中api地址
$endPoint = '<region endPoint>';
//替換為應(yīng)用名
$appName = '<app name>';
//替換為下拉提示名稱
$suggestName = '<suggest name>';
//開啟調(diào)試模式
$options = array('debug' => true);
//創(chuàng)建OpenSearchClient客戶端對象
$client = new OpenSearchClient($accessKeyId, $secret, $endPoint, $options);
上傳文檔代碼
以下我們向 opensearch應(yīng)用中上傳了10條文檔。
<?php
header("Content-Type:text/html;charset=utf-8");
//引用頭部文件
require_once("Config.inc.php");
use OpenSearch\Client\DocumentClient;
use OpenSearch\Client\SearchClient;
use OpenSearch\Util\SearchParamsBuilder;
//設(shè)置數(shù)據(jù)需推送到對應(yīng)應(yīng)用表中
$tableName = '替換應(yīng)用表名';
//創(chuàng)建文檔操作client
$documentClient = new DocumentClient($client);
//添加數(shù)據(jù)
$docs_to_upload = array();
for ($i = 0; $i < 10; $i++){
$item = array();
$item['cmd'] = 'ADD';
$item["fields"] = array(
"id" => $i + 1,
"name" => "搜索肯德基".$i
);
$docs_to_upload[] = $item;
}
// 編碼
$json = json_encode($docs_to_upload);
//提交推送文檔
$ret = $documentClient->push($json, $appName, $tableName);
//延遲10秒,高級版主表增量90%,10秒內(nèi)生效,99%在10min內(nèi),附表暫不保證。
sleep(10);
// 實例化一個搜索類
$searchClient = new SearchClient($client);
// 實例化一個搜索參數(shù)類
$params = new SearchParamsBuilder();
//設(shè)置config子句的start值
$params->setStart(0);
//設(shè)置config子句的hit值
$params->setHits(20);
// 指定一個應(yīng)用用于搜索
$params->setAppName('替換為應(yīng)用名');
// 指定搜索關(guān)鍵詞
$params->setQuery("name:'搜索'");
// 指定返回的搜索結(jié)果的格式為json
$params->setFormat("fulljson");
//添加排序字段
$params->addSort('RANK', SearchParamsBuilder::SORT_DECREASE);
// 執(zhí)行搜索,獲取搜索結(jié)果
$ret = $searchClient->execute($params->build());
// 將json類型字符串解碼
print_r(json_decode($ret->result,true));
//打印調(diào)試信息
echo $ret->traceInfo->tracer;