OpenSearch:Query data statistics

Java

<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-sdk-ha3engine-vector</artifactId>
    <version>1.1.8</version>
</dependency>

Python

# Requires: Python >=3.6
pip install alibabacloud_ha3engine_vector

Go

go get github.com/aliyun/alibabacloud-ha3-go-sdk@v1.1.8-vector

Java in asynchronous mode

<dependency>
  <groupId>com.aliyun</groupId>
  <artifactId>aliyun-sdk-ha3engine-async</artifactId>
  <version>1.1.4</version>
</dependency>

Java

package com.aliyun.ha3engine.demo;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;

import com.aliyun.ha3engine.vector.Client;
import com.aliyun.ha3engine.vector.models.Config;
import com.aliyun.ha3engine.vector.models.SearchResponse;
import com.aliyun.tea.TeaException;

import org.junit.Before;
import org.junit.Test;

public class Demo {

    /**
     * The engine client of the OpenSearch Vector Search Edition instance.
     */
    private Client client;

    @Before
    public void clientInit() throws Exception {

        /*
          Initialize the engine client.
         */
        Config config = new Config();

        // The name of the OpenSearch Vector Search Edition instance. You can view the instance name in the upper-left corner of the Instance Details page. Example: ha-cn-i7*****605.
        config.setInstanceId("ha-cn-i7*****605");

        // The username. You can view the username on the API Endpoint section of the Instance Details page.
        config.setAccessUserName("username");

        // The password. You can modify the password on the API Endpoint section of the Instance Details page.
        config.setAccessPassWord("password");

        // To access the instance by using an internal endpoint, specify the endpoint.
        config.setEndpoint("ha-cn-i7*****605.public.ha.aliyuncs.com");
        // To access the instance over the Internet, uncomment the following line and specify the HTTP proxy.
        // config.setHttpProxy("http://116.62.***.***:80");

        client = new Client(config);

    }

    @Test
    public void stats() throws Exception {
        try {
            SearchResponse searchResponse = client.stats("gist");
            System.out.println("Result:\n" + searchResponse.getBody());
        } catch (TeaException e) {
            System.out.println(e.getCode());
            System.out.println(e.getMessage());
            Map<String, Object> abc = e.getData();
            System.out.println(com.aliyun.teautil.Common.toJSONString(abc));
        }
    }

}

Python

from alibabacloud_ha3engine_vector.client import Client
from alibabacloud_ha3engine_vector.models import Config

config = Config(
        # To access the instance by using an internal endpoint, specify the endpoint.
        endpoint="ha-cn-7mz2ougaw02.ha.aliyuncs.com",
        # The name of the OpenSearch Vector Search Edition instance. You can view the instance name in the upper-left corner of the Instance Details page. Example: ha-cn-i7*****605.
        instance_id="ha-cn-7mz2ougaw02",
        # The username. You can view the username in the API Endpoint section of the Instance Details page.
        access_user_name="user",
        # The password. You can modify the password in the API Endpoint section of the Instance Details page.
        access_pass_word="111111")
client = Client(config)

result = client.stats("gist")

Go

package main

import (
	"fmt"
	"github.com/alibabacloud-go/tea/tea"
	ha3engine "github.com/aliyun/alibabacloud-ha3-go-sdk/client"
)

func main() {

	// Create a Config instance.
	config := &ha3engine.Config{
		// The internal or public endpoint.
		Endpoint: tea.String("<Endpoint>"),
		// The name of the OpenSearch Vector Search Edition instance. You can view the instance name in the upper-left corner of the Instance Details page. Example: ha-cn-i7*****605.
		InstanceId: tea.String("<InstanceId>"),
		// The username. You can view the username on the API Endpoint section of the Instance Details page.
		AccessUserName: tea.String("<AccessUserName>"),
		// The password. You can modify the password on the API Endpoint section of the Instance Details page.
		AccessPassWord: tea.String("<AccessPassWord>"),
	}

	// Initialize a client for sending requests.
	client, _clientErr := ha3engine.NewClient(config)

	// If an error occurs when the system creates the client, _clientErr and an error message are returned.
	if _clientErr != nil {
		fmt.Println(_clientErr)
		return
	}

	stats(client)
}

/**
 * Query data statistics
 */
func stats(client *ha3engine.Client) {
	response, _requestErr := client.Stats(tea.String("api"))

	// If an error occurs when the system sends the request, _requestErr and an error message are returned.
	if _requestErr != nil {
		fmt.Println(_requestErr)
		return
	}

	// Display the response if no error occurs.
	fmt.Println(response)

}

Java in asynchronous mode

package com.aliyun.ha3engine;

import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

import com.aliyun.ha3engine.async.AsyncClient;
import com.aliyun.ha3engine.async.models.SearchResponse;
import com.aliyun.ha3engine.async.models.StatsRequest;
import com.aliyun.sdk.ha3engine.async.core.AsyncConfigInfoProvider;
import com.aliyun.tea.TeaException;

import darabonba.core.client.ClientOverrideConfiguration;

/**
 * @author alibaba
 */
public class SearchDoc {

    public static void main(String[] args) throws Exception {
        try {
            // The username and password that are used to access the instance. You can view the username and password in the API Endpoint section of the Instance Details page.
            AsyncConfigInfoProvider provider = AsyncConfigInfoProvider.create("username", "password");

            // Initialize the asynchronous client.
            AsyncClient client = AsyncClient.builder()
                    .credentialsProvider(provider)
                    .overrideConfiguration(
                            ClientOverrideConfiguration.create()
                                    // The public endpoint of the instance. You can view the public endpoint in the Network Information section of the Instance Details page.
                                    .setEndpointOverride("ha-cn-***********.public.ha.aliyuncs.com")
                            .setProtocol("http")
                    ).build();
            StatsRequest statsRequest = StatsRequest.builder().tableName("table_name").build();
            CompletableFuture<SearchResponse> searchResponseCompletableFuture = client.stats(statsRequest);
            String responseBody = searchResponseCompletableFuture.get().getBody();

            System.out.println("result: " + responseBody);

        } catch (ExecutionException | InterruptedException e) {
            System.out.println(e.getMessage());
        } catch (TeaException e) {
            System.out.println(e.getMessage());
            Map<String, Object> abc = e.getData();
            System.out.println(com.aliyun.teautil.Common.toJSONString(abc));
        }
    }
}