OpenSearch：文檔推送Demo

Package 依賴地址：https://www.nuget.org/packages

dotnet add package AlibabaCloud.TeaUtil --version  0.1.5
dotnet add package AlibabaCloud.OpenSearchUtil --version 1.0.2
dotnet add package Aliyun.Credentials --version  1.2.1
dotnet add package Tea --version 0.4.0

以下是C# SDK 文檔推送的範例程式碼：

using System;
using System.Collections.Generic;
using AlibabaCloud.TeaUtil.Models;
using Tea;

namespace ConsoleApp2
{
    internal class Program
    {
        public static Dictionary<string, object> docBulk(Client opensearchClient, string appName,
            string tableName, List<object> docContent, Dictionary<string, string> header, RuntimeOptions runTime)
        {
            string pathName = "/v3/openapi/apps/" + appName + "/" + tableName + "/actions/bulk";
            try
            {
                return opensearchClient._request("POST", pathName, null, header, docContent, runTime);
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
                throw;
            }
        }


        private static void Main(string[] args)
        {
            var runtime = new RuntimeOptions
            {
                ConnectTimeout = 5000,
                ReadTimeout = 10000,
                MaxAttempts = 0,
                Autoretry = false,
                IgnoreSSL = false,
                MaxIdleConns = 50
            };

            var config = new Config
            {
                // 配置統一的請求入口, 此資訊可從業務控制台擷取.
                Endpoint = "opensearch-cn-hangzhou.aliyuncs.com",

                // 支援 protocol 配置 HTTPS/HTTP
                Protocol = "HTTPS",

                /* 使用者識別資訊
                從環境變數讀取配置的AccessKey ID和AccessKey Secret，
                運行程式碼範例前必須先配置環境變數，參考文檔上面“配置環境變數”步驟 */
                AccessKeyId =  System.Environment.GetEnvironmentVariable("ALIBABA_CLOUD_ACCESS_KEY_ID"),
                AccessKeySecret = System.Environment.GetEnvironmentVariable("ALIBABA_CLOUD_ACCESS_KEY_SECRET"),


                // 支援 type 配置 sts/access_key 鑒權. 其中 type 預設為 access_key 鑒權. 使用 sts 可配置 RAM-STS 鑒權.
                // 備選參數為：sts 或者 access_key
                Type = "access_key",

                // 如果使用 RAM-STS 鑒權, 請配置 security_token, 可使用阿里雲 AssumeRole 擷取相關 STS 鑒權結構.
                SecurityToken = "",
            };

            // 建立 opensearch client 執行個體
            var openSearch = new Client(config);

            // 要搜尋的appName.
            var appName = "appName";

            // 推送的目標表. 
            var tableName = "tableName";

            // 自訂HttpHeaders .
            var header = new Dictionary<string, string>();


            // 文檔結構構造. 
            // timestamp 資訊用以增加對文檔操作的保序能力. 系統會用該時間戳記來作為同一主鍵文檔更新順序的判斷標準.
            // 在沒有該timestamp項時，預設以文檔發送到OpenSearch的時間作為文檔更新時間進行操作。
            List<object> documents = new List<object>();
            Dictionary<string, object> document = new Dictionary<string, object>();
            Dictionary<string, object> document1 = new Dictionary<string, object>();
            Dictionary<string, object> fields = new Dictionary<string, object>();
            fields.Add("id", DateTime.Now.Millisecond);
            fields.Add("text", DateTime.Now.Millisecond);
            fields.Add("title", DateTime.Now.Millisecond);
            fields.Add("cate", DateTime.Now.Millisecond);
            document.Add("cmd", "ADD");
            document.Add("fields", fields);
            document1.Add("cmd", "ADD");
            document1.Add("timestamp", DateTime.Now.Second);
            document1.Add("fields", fields);
            documents.Add(document);
            documents.Add(document1);


           
            try
            {
                docBulk(openSearch, appName, tableName, documents, header, runtime);
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
                throw;
            }
        }
    }
}