OpenSearch:Query data

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.QueryRequest;
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. The client supports query operations.
     */
    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 in the API Endpoint section of the Instance Details page.
        config.setAccessUserName("username");

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

        // To access the instance by using an internal endpoint, specify the endpoint. To access the instance by using a public endpoint, uncomment the following line:
        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.XXX.XXX:80");

        client = new Client(config);

    }

    @Test
    public void query() throws Exception {
        try {
            QueryRequest request = new QueryRequest();
            request.setTableName("gist"); // Required. The name of the table to be queried.
            request.setVector(Arrays.asList(0.183762561f, 0.738372617f)); // Required. The vector data to be queried.
            request.setNamespace("namespace"); // Optional. The namespace of the vector to be queried.
            request.setTopK(100); // Optional. The number of results to be returned.
            request.setIncludeVector(true); // Optional. Specifies whether to return the vector information in documents.
            request.setSearchParams("{\\\"qc.searcher.scan_ratio\\\":0.01}");
            SearchResponse searchResponse = client.query(request);
            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));
        }
    }

}

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

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)

request = QueryRequest(table_name="t1",
                        namespace="space_b",
                        vector=[0.1, 0.2],
                        include_vector=True,
                        search_params="{\\\"qc.searcher.scan_ratio\\\":0.01}",
                        top_k=10)
result = client.query(request)

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.*;
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. The client supports query operations.
     */
    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 in the API Endpoint section of the Instance Details page.
        config.setAccessUserName("username");

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

        // To access the instance by using an internal endpoint, specify the endpoint. To access the instance by using a public endpoint, uncomment the following line:
        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.XXX.XXX:80");

        client = new Client(config);

    }

    @Test
    public void multiQuery() throws Exception {
        try {
            MultiQueryRequest request = new MultiQueryRequest();
            request.setTableName("gist");
            request.setTopK(3);
            request.setIncludeVector(true);

            QueryRequest query1 = new Query();
            query1.setVector(Arrays.asList(0.1f, 0.2f, 0.3f));
            query1.setNamespace("space_a");

            QueryRequest query2 = new Query();
            query2.setVector(Arrays.asList(0.1f, 0.2f, 0.3f));
            query2.setNamespace("space_b");

            request.setQueries(Arrays.asList(query1, query2));
							
            SearchResponse searchResponse = client.multiQuery(request);
            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));
        }
    }

}

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

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)

q1 = QueryRequest(vector=[0.1, 0.2, 0.3], namespace="space_a")
q2 = QueryRequest(vector=[0.4, 0.5, 0.6], namespace="space_b")
request = MultiQueryRequest(table_name = "gist", 
                                 queries=[q1, q2], 
                                 top_k=3, 
                                 include_vector=True)
result = client.multi_query(request)

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.QueryRequest;
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. The client supports query operations.
     */
    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 in the API Endpoint section of the Instance Details page.
        config.setAccessUserName("username");

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

        // To access the instance by using an internal endpoint, specify the endpoint. To access the instance by using a public endpoint, uncomment the following line:
        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.XXX.XXX:80");

        client = new Client(config);

    }

    @Test
    public void query() throws Exception {
        try {
            QueryRequest request = new QueryRequest();
            request.setTableName("gist"); // Required. The name of the table to be queried.
            request.setVector(Arrays.asList(0.183762561f, 0.738372617f)); // Required. The vector data to be queried.
            request.setTopK(100); // Optional. The number of results to be returned.
            request.setIncludeVector(true); // Optional. Specifies whether to return the vector information in documents.
            request.setOutputFields(new ArrayList<String>()); // Optional. The fields to be returned.
            request.setFilter("a>10"); // Optional. The filter expression.
            request.setSearchParams("{\\\"qc.searcher.scan_ratio\\\":0.01}");
            SearchResponse searchResponse = client.query(request);
            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));
        }
    }

}

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

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)

request = QueryRequest(table_name="t1",
                        vector=[0.1, 0.2],
                        include_vector=True,
                        filter="a > 10",
                        output_fields=["a", "b"],
                        search_params="{\\\"qc.searcher.scan_ratio\\\":0.01}",
                        top_k=10)
result = client.query(request)

import com.aliyun.ha3engine.vector.Client;
import com.aliyun.ha3engine.vector.models.*;
import com.aliyun.tea.TeaException;
import org.junit.Before;
import org.junit.Test;

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

public class Demo {

    /**
     * The engine client of the OpenSearch Vector Search Edition instance. The client supports query operations.
     */
    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-***********");

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

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

        // To access the instance by using an internal endpoint, specify the endpoint. To access the instance by using a public endpoint, uncomment the following line:
        config.setEndpoint("ha-cn-**********.public.ha.aliyuncs.com");
        // To access the instance over the Internet, uncomment the following line and specify the HTTP proxy.
//		config.setHttpProxy("http://120.27.XXX.XX:80");
        client = new Client(config);
    }
    
    @Test
    public void query() throws Exception {
        try {
            QueryRequest queryRequest = new QueryRequest();
            queryRequest.setIndexName("vector"); // The name of the index to be queried. Specify this parameter in SearchRequest or in each query.
            queryRequest.setNamespace("xxx"); // The namespace of the vector data.
            queryRequest.setVector(Arrays.asList(0.0001575F, 0.00682848F)); // The vector data to be queried. The data is of the ARRAY type.

            SparseData sparseData = new SparseData();
            sparseData.setCount(Arrays.asList(2)); // The number of elements in each sparse vector.
            sparseData.setIndices(Arrays.asList(983589459L, 1261855554L)); // The indexes of the elements in ascending order.
            sparseData.setValues(Arrays.asList(0.0001575F, 0.00682848F)); // The values of the elements in the same order as the indexes.

            queryRequest.setSparseData(sparseData);

            SearchResponse searchResponse = client.query(queryRequest);
            System.out.println(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));
        }
    }
}

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

config = Config(
    # To access the instance by using an internal endpoint, specify the endpoint.
    endpoint="ha-***",
    # 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-***",
    # The username. You can view the username in the API Endpoint section of the Instance Details page.
    access_user_name="xxx",
    # The password. You can modify the password in the API Endpoint section of the Instance Details page.
    access_pass_word="xxx")
client = Client(config)
sparseData = SparseData(indices=[101, 203], values=[0.1, 0.5])
request = QueryRequest(table_name="t1",
                       index_name="vec_index",
                       vector=[0.1, 0.2, 0.3, 0.4],
                       sparse_data=sparseData
                       include_vector=True,
                       output_fields=["a", "b"],
                       top_k=10)
result = client.query(request)

import com.aliyun.ha3engine.vector.Client;
import com.aliyun.ha3engine.vector.models.*;
import com.aliyun.tea.TeaException;
import org.junit.Before;
import org.junit.Test;

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

public class Demo {

    /**
     * The engine client of the OpenSearch Vector Search Edition instance. The client supports query operations.
     */
    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-***********");

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

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

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

        client = new Client(config);
    }

    @Test
    public void query() throws Exception {
        try {

            MultiQueryRequest multiQueryRequest = new MultiQueryRequest();

            multiQueryRequest.setTableName("main"); // The name of the table to be queried.
            multiQueryRequest.setTopK(50); // The number of results to be returned.
            multiQueryRequest.setOutputFields(Arrays.asList("content", "source", "instance_id")); // The fields to be returned.
            multiQueryRequest.setFilter("type='TEXT'"); // The filter expression.
            multiQueryRequest.setOrder("DESC");

            QueryRequest queryRequest = new QueryRequest();
            queryRequest.setIndexName("vector"); // The name of the index to be queried. Specify this parameter in SearchRequest or in each query.
            queryRequest.setNamespace("xxx"); // The namespace of the vector data.
            queryRequest.setVector(Arrays.asList(0.0001575F, 0.00682848F)); // The vector data to be queried. The data is of the ARRAY type.

            SparseData sparseData = new SparseData();
            sparseData.setCount(Arrays.asList(2)); // The number of elements in each sparse vector.
            sparseData.setIndices(Arrays.asList(983589459L, 1261855554L)); // The indexes of the elements in ascending order.
            sparseData.setValues(Arrays.asList(0.0001575F, 0.00682848F)); // The values of the elements in the same order as the indexes.

            queryRequest.setSparseData(sparseData);
            multiQueryRequest.setQueries(Arrays.asList(queryRequest));

            SearchResponse searchResponse = client.multiQuery(multiQueryRequest);
            System.out.println(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));
        }
    }
}

from alibabacloud_ha3engine_vector.client import Client
from alibabacloud_ha3engine_vector.models import Config
from alibabacloud_ha3engine_vector.models import SparseData
from alibabacloud_ha3engine_vector.models import QueryRequest
from alibabacloud_ha3engine_vector.models import MultiQueryRequest

config = Config(
        # To access the instance by using an internal endpoint, specify the endpoint.
        endpoint="ha-***",
        # 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-***",
        # The username. You can view the username in the API Endpoint section of the Instance Details page.
        access_user_name="xxx",
        # The password. You can modify the password in the API Endpoint section of the Instance Details page.
        access_pass_word="xxx")
client = Client(config)
sd1 = SparseData(indices=[101, 203], values=[0.1, 0.5])
sd2 = SparseData(indices=[200, 405, 502], values=[0.9, 0.5, 0.75])
q1 = QueryRequest(vector=[0.1, 0.2, 0.3], namespace="space_a", sparse_data=sd1)
q2 = QueryRequest(vector=[0.4, 0.5, 0.6], namespace="space_b", sparse_data=sd2)
request = MultiQueryRequest(table_name = "gist", 
                                 queries=[q1, q2], 
                                 top_k=3, 
                                 include_vector=True)
result = client.multi_query(request)