如何通過API/SDK匯入資料 - OpenSearch

OpenSearch行業演算法版提供三種接入方案：使用者可選擇通過API/SDK匯入以獲得最大靈活性；對於輕量化測試，可使用控制台直接上傳小批量資料；需對接雲端資料庫時，系統支援與RDS、MaxCompute、PolarDB等資料來源的自動化管道同步，通過可視化配置實現自動化管道同步。

欄位類型對應關係

OpenSearch 欄位類型	API推送欄位類型
INT	int、long
INT_ARRAY	int [] 、long []
FLOAT	float
FLOAT_ARRAY	float []
DOUBLE	double
DOUBLE_ARRAY	double []
LITERAL	string
LITERAL_ARRAY	string []
SHORT_TEXT	string
TEXT	string
TIMESTAMP	long
GEO_POINT	string，格式為：lon lat。lon表示經度，lat表示緯度，都為double類型，二者之間用空格分隔。lon的範圍：[-180, 180], lat範圍[-90, 90]。

API推送資料

控制台上傳檔案的功能一般用於搜尋功能測試，不適用於大量文檔上傳，效率比較低，一次只能上傳2M大小的文檔。其他API/SDK更多推送系統限制，點擊此處查看文檔。

在執行個體管理頁面的執行個體列表中，找到目標執行個體，單擊操作列的下拉式功能表，選擇上傳檔案。

API/SDK不支援設定資料來源外掛程式，請自行拼接、處理後傳入OpenSearch應用中。比如，array類型使用API上傳時，注意不要上傳為string格式，而是上傳為數群組類型。例：

//定義MapObject Storage Service上傳文檔資料,此為文檔2
Map<String,Object> doc2 =Maps.newLinkedHashMap();
     doc2.put("id",1);
String[] literal_arr2 ={"元素1","元素2"};
     doc2.put("literal_arr", literal_arr2);

API/SDK具體請參見：

API開發人員指南

Java SDK： Commit推送Demo 、Push推送Demo

Php SDK ：Push推送Demo、Push推送帶搜尋Demo

Go SDK ：行為資料推送Demo、Push推送Demo

TypeScript/Node.js SDK：安裝@alicloud/opensearch-sdk包。

npm install @alicloud/opensearch-sdk

通過pushDocument介面推送資料：

import Client, { Config, Document, PushDocumentRequestModel } from '@alicloud/opensearch-sdk';

// 使用AccessKey鑒權
const config = new Config({
  endpoint: 'opensearch-cn-beijing.aliyuncs.com',  // 流量接入地址，橫杠格式
  accessKeyId: process.env.ALIBABA_CLOUD_ACCESS_KEY_ID,
  accessKeySecret: process.env.ALIBABA_CLOUD_ACCESS_KEY_SECRET,
});
const client = new Client(config);

// 構造待推送文檔
const docs = [
  new Document({
    cmd: 'ADD',
    fields: { id: '1', title: '範例文件', body: '文檔內容' },
  }),
];

// 推送資料到指定應用的表
const request = new PushDocumentRequestModel({ body: docs });
const response = await client.pushDocument('應用程式名稱', '表名', request);
console.log(response.body);

不同地區的流量接入endpoint格式為opensearch-cn-{region}.aliyuncs.com，例如杭州地區對應opensearch-cn-hangzhou.aliyuncs.com。SDK鑒權使用阿里雲AccessKey（AK/SK），通過Config傳入，不使用API-key方式。

OpenSearch提供兩個npm包：@alicloud/opensearch-sdk用於流量API（搜尋、資料推送、下拉提示），@alicloud/opensearch20171225用於管控API（應用管理）。資料推送情境使用@alicloud/opensearch-sdk。

OpenSearch：API/SDK資料匯入

欄位類型對應關係

API推送資料

相關連結