通过客户端访问阿里云Elasticsearch

准备工作

• 安装Java，要求JDK版本为1.8及以上。

  安装方法请参见安装JDK。

• 创建阿里云Elasticsearch实例。
  具体操作步骤请参见创建阿里云Elasticsearch实例。

  说明 建议创建与客户端相同版本的实例，避免出现兼容性问题。Elasticsearch与客户端版本兼容性的详细信息，请参见Compatibility。
• 开启阿里云Elasticsearch实例的自动创建索引功能。

  具体操作步骤请参见配置YML参数。

• 配置阿里云Elasticsearch实例的白名单，确保网络互通。
  • 如果运行代码的服务器在公网环境下，可通过阿里云Elasticsearch实例的公网地址进行连通。连通前，需要开启阿里云Elasticsearch实例的公网地址，并修改公网地址访问白名单，将服务器的公网IP地址加入白名单中。具体操作步骤请参见配置实例公网或私网访问白名单。
    注意

    • 如果您使用的是WIFI、宽带等网络，需要将公网出口的跳板机IP地址配置进去。
    • 您也可以将白名单配置为0.0.0.0/0，允许所有IPv4地址访问阿里云Elasticsearch实例。此配置会导致实例完全暴露在公网中，增加安全风险，配置前请确认您是否可以接受这个风险。
  • 如果运行代码的服务器与阿里云Elasticsearch实例在同一专有网络VPC（Virtual Private Cloud）中，可通过阿里云Elasticsearch实例的内网地址进行连通。连通前，需要确保VPC私网访问白名单（默认为0.0.0.0/0）中已添加了服务器的内网IP地址。

PHP语言

<?php
require 'vendor/autoload.php';
use Elasticsearch\ClientBuilder;

$client = ClientBuilder::create()->setHosts([
  [
    'host'   => '<YourEsHost>',
    'port'   => '9200',
    'scheme' => 'http',
    'user'   => '<UserName>',
    'pass'   => '<YourPassword>'
  ]
])->setConnectionPool('\Elasticsearch\ConnectionPool\SimpleConnectionPool', [])
  ->setRetries(10)->build();

$indexParams = [
  'index'  => '<YourEsIndex>',
  'type'   => '<YourEsType>',
  'id'     => '<YourEsId>',
  'body'   => ['<YourEsField>' => '<YourEsFieldValue>'],
  'client' => [
    'timeout'         => 10,
    'connect_timeout' => 10
  ]
];
$indexResponse = $client->index($indexParams);
print_r($indexResponse);

$searchParams = [
  'index'  => '<YourEsIndex>',
  'type'   => '<YourEsType>',
  'body'   => [
    'query' => [
      'match' => [
        '<YourEsField>' => '<YourEsFieldValue>'
      ]
    ]
  ],
  'client' => [
    'timeout'         => 10,
    'connect_timeout' => 10
  ]
];
$searchResponse = $client->search($searchParams);
print_r($searchResponse);
?>

使用代码时，您需要将以下字段替换为对应的值。

Elasticsearch PHP客户端的详细信息，请参见Elasticsearch-PHP。

Python语言

通过Python客户端访问阿里云Elasticsearch的9200端口进行测试，示例代码如下。

from elasticsearch import Elasticsearch, RequestsHttpConnection
import certifi
es = Elasticsearch(
    ['<YourEsHost>'],
    http_auth=('<UserName>', '<YourPassword>'),
    port=9200,
    use_ssl=False
)
res = es.index(index="<YourEsIndex>", doc_type="<YourEsType>", id=<YourEsId>, body={"<YourEsField1>": "<YourEsFieldValue1>", "<YourEsField2>": "<YourEsFieldValue2>"})
res = es.get(index="<YourEsIndex>", doc_type="<YourEsType>", id=<YourEsId>)
print(res['_source'])

使用代码时，您需要将以下字段替换为对应的值。

Elasticsearch Python客户端的详细信息，请参见Elasticsearch Python Client。

Java语言

Go语言

使用Go语言连接阿里云Elasticsearch前，您需要先安装Go编译环境，详细信息请参见The Go Programming Language。以下示例代码使用Go 1.13.4版本访问阿里云Elasticsearch的9200端口进行测试。

package main

import (
    "context"
    "gopkg.in/olivere/elastic.v5"
    "gopkg.in/olivere/elastic.v5/config"
    "log"
)

const (
    url      = "<YourEsHost>"     
    username = "<UserName>"        
    password = "<YourPassword>"       
)

func main() {
    var sniff = false     
    cfg := &config.Config{
        URL:      url,
        Username: username,
        Password: password,
    }

    cfg.Sniff = &sniff          
    var client, err = elastic.NewClientFromConfig(cfg)
    if err != nil {
        log.Println(err)
        return
    }

    exists, err := client.IndexExists("<YourEsIndex>").Do(context.Background())   //在阿里云Elasticsearch上新建一个索引，并根据连接状态返回日志信息。
    if err != nil {
        log.Println(err)
    }
    log.Println(exists)
}

使用代码时，您需要将以下字段替换为对应的值。

连接成功后，返回如下结果。

2019/11/29 10:07:37 true

相关文档

更多Elasticsearch客户端：Elasticsearch Clients