代碼示例

// This file is auto-generated, don't edit it. Thanks.
package main

import (
    "fmt"
    util "github.com/alibabacloud-go/tea-utils/service"
    "github.com/alibabacloud-go/tea/tea"
    opensearch "main/client"
)

func main() {
    // 創(chuàng)建請求用客戶端實例
    // Endpoint 為 要訪問服務(wù)的區(qū)域域名.
    // AccessKeyId 及AccessKeySecret 用于構(gòu)造鑒權(quán)信息.
    config := &opensearch.Config{
        Endpoint:         tea.String( "<Endpoint>"),
        // 用戶識別信息
        // 從環(huán)境變量讀取配置的AccessKey ID和AccessKey Secret，
        // 運行代碼示例前必須先配置環(huán)境變量，參考文檔上面“配置環(huán)境變量”步驟
        // 替換對應(yīng)的access key id
        AccessKeyId:     tea.String(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")),
        AccessKeySecret: tea.String(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET")),
    }

    // New  一個client, 用以發(fā)送請求.
    client, _clientErr := opensearch.NewClient(config)

    // 如果 NewClient 過程中出現(xiàn)異常. 則 返回 _client_err 且輸出 錯誤信息.
    if _clientErr != nil {
        fmt.Println(_clientErr)
        return
    }

    // 組裝文檔
    // 必備信息: 推送數(shù)據(jù) 內(nèi)必須包含 primaryKey  field 信息(opensearch結(jié)構(gòu)表的主鍵字段). 否則將無法更新文檔.
    //          更新的其他 doc 字段及內(nèi)容信息. 以 UTF-8 編碼.
    // opensearch 支持 'ADD' 及 'DELETE' 命令.分別實現(xiàn) 新增 和刪除 doc 動作.
    
    document1st := map[string]interface{}{
        "cmd": "ADD",
        "fields": map[string]interface{}{
            "id":       1,  //  如文例所示. id 為 文檔主鍵字段.
            "describe": "123456",  // doc 字段.
        },
    }

    // timestamp 信息 用以增加對 文檔操作的保序能力. 系統(tǒng)會用該時間戳來作為同一主鍵文檔更新順序的判斷標準.
    // 在沒有該timestamp項時，默認以文檔發(fā)送到OpenSearch的時間作為文檔更新時間進行操作。
    document2nd := map[string]interface{}{
        "cmd": "ADD",
        "timestamp": 1401342874778,
        "fields": map[string]interface{}{
            "id":       2,
            "describe": "123456",
        },
    }

    // 組裝推送文檔 數(shù)組結(jié)構(gòu). 其中包含單條文檔動作.
    requestBody := []interface{}{document1st}

    // 此結(jié)構(gòu)可進行多個 document append 動作.
    requestBody = append(requestBody, document2nd)

    // 請求發(fā)送的配置參數(shù). 用以請求配置及連接池配置.
    runTime := &util.RuntimeOptions{
        ConnectTimeout: tea.Int(5000),
        ReadTimeout:    tea.Int(10000),
        Autoretry:      tea.Bool(false),
        IgnoreSSL:      tea.Bool(false),
        MaxIdleConns:   tea.Int(50),
    }

    // 推送接口需要提供 推送 app 和表名,
    // App 可以是 app 的版本信息. 也可以是 app 名稱.
    // 推送表為 為 目標表的名稱. 可在控制臺查看.
    appName := "<appName>"
    tableName := "<tableName>"

    // 發(fā)送請求的方法調(diào)用.
    response, _requestErr := client.Request(
        tea.String("POST"),
        tea.String("/v3/openapi/apps/"+appName+"/"+tableName+"/actions/bulk"),
        nil,
        nil,
        requestBody,
        runTime)

    // 如果 發(fā)送請求 過程中出現(xiàn)異常. 則 返回 _requestErr 且輸出 錯誤信息.
    if _requestErr != nil {
        fmt.Println(_requestErr)
        return
    }

    // 輸出正常返回的 response 內(nèi)容.
    fmt.Println(response)
}