Polygon Weekly AMA

活动主题：

《Polygon开发者入门Workshop——从️搭建自己的LendingPool》

活动时间：

9月11号晚上7点

活动举办方：

Polygon x SolidStake x Elastic中文社区

活动地点：

扫码进AMA微信群！ 会议号是：193 658 608

1.怎么为每个索引选择合适的分片？

https://opster.com/elasticsearch-glossary/elasticsearch-choose-number-of-shards/?kinsta-cache-cleared=true

2.在kibana使用德国高速公路数据示例

https://spinscale.de/posts/2021-09-01-using-german-highway-api-data-with-kibana-maps.html

3.在es查询中查找实体名的方法

https://stackoverflow.com/questions/55989250/how-to-find-entity-in-search-query-in-elasticsearch

将索引从一个集群（ip：192.168.0.1）迁移到另一个集群（ip：192.168.0.2），新集群需要配置白名单：

# elasticsearch.yml
reindex.remote.whitelist: ['192.168.0.1:9200']

import json

import requests

import base64

# 迁移索引数据
def reindex(index):
    print("{0} 索引正在迁移中".format(index))
    jsonData = {
        "source": {
            "remote": {
                "host": "http://192.168.0.1:9200",
                "socket_timeout": "30s",
                "connect_timeout": "30s",
                "username": "elastic",
                "password": "123456"
            },
            "index": index
        },
        "dest": {
            "index": index
        }
    }
    res = requests.post("http://192.168.0.2:9200/_reindex", json=jsonData)
    print(res.status_code)
    print(res.content)

# 获取创建索引的语句
def getIndexDslJson(index):

    username = "elastic"
    password = "123456"
    user_info_str = username + ":" + password
    user_info = base64.b64encode(user_info_str.encode())  # 这个得到是个字节类型的数据
    headers = {
        "Authorization": "Basic {0}".format(user_info.decode())  # 这个就是需要验证的信息
    }

    res = requests.get("http://192.168.0.1:9200/{0}".format(index),
                       headers=headers)
    print(res.status_code)
    jsonIndex = json.loads(res.content)
    print(jsonIndex[index])
    del jsonIndex[index]['settings']['index']['creation_date']
    del jsonIndex[index]['settings']['index']['provided_name']
    del jsonIndex[index]['settings']['index']['uuid']
    del jsonIndex[index]['settings']['index']['version']
    jsonIndex[index]['settings']['index']['number_of_shards'] = 1
    jsonIndex[index]['settings']['index']['number_of_replicas'] = 0
    return jsonIndex[index]

# 创建索引
def createIndex(index, dslJson):
    res = requests.put("http://192.168.0.2:9200/{0}".format(index), json=dslJson)
    print(res.status_code)
    print(res.content)

if __name__ == '__main__':
    # 需要创建的索引
    indexList = [
        "index1_v1", "index2_v1"
    ]
    for index in indexList:
        dslJson = getIndexDslJson(index) # 获取原索引的结构
        createIndex(index, dslJson) # 根据原索引结构，在新集群创建索引
        reindex(index) # 将原集群索引迁移到新集群

创建es账号并授权

# 创建账号
adduser es

# 修改密码
passwd es   

# 授权
chmod -v u+w /etc/sudoers
vim /etc/sudoers

#新增
es ALL=(ALL) ALL

# wq保存退出，这时候要记得将写权限收回
chmod -v u-w /etc/sudoers

创建docker网络

docker network create tx

安装Elasticsearch

docker pull elasticsearch:6.7.1

在/home/es 中创建 config,data,plugins目录
在plugins目录中下载es相关插件，如：ik,pinyin等
在config中创建elasticsearch.yml配置，创建analysis\synonym.txt 同义词
给data配置权限 sudo chmod 777 /home/es/data/
将/home/es 目录及其子目录的用户改为es：chown -R es:root /home/es/

# elasticsearch.yml
cluster.name: "my-docker-cluster"
node.name: "es-node1"
network.host: 0.0.0.0
http.port: 9200
http.cors.enabled: true
http.cors.allow-origin: "*"
http.cors.allow-headers: "Authorization,X-Requested-With,Content-Length,Content-Type"
node.master: true
reindex.remote.whitelist: ['other:9200']

xpack.security.enabled: true
xpack.security.authc.api_key.enabled: true
#xpack.security.transport.ssl.enabled: true
#xpack.security.transport.ssl.verification_mode: certificate 
#xpack.security.transport.ssl.keystore.path: elastic-certificates.p12
#xpack.security.transport.ssl.truststore.path: elastic-certificates.p12

docker run -d --net tx --name my_elasticsearch -p 9201:9200 -p 9301:9300 -v /home/es/config/elasticsearch.yml:/usr/share/elasticsearch/config/elasticsearch.yml -v /home/es/config/analysis:/usr/share/elasticsearch/config/analysis -v /home/es/config/elastic-certificates.p12:/usr/share/elasticsearch/config/elastic-certificates.p12 -v /home/es/data:/usr/share/elasticsearch/data -v /home/es/plugins:/usr/share/elasticsearch/plugins -e "discovery.type=single-node" -i -t --privileged=true elasticsearch:6.7.1

安装kibana

docker pull kibana:6.7.1

# kibana.yml配置文件
server.name: kibana
server.host: 0.0.0.0
elasticsearch.hosts: ["http://my_elasticsearch:9200"]
i18n.locale: "zh-CN"
elasticsearch.username: "elastic"
elasticsearch.password: "123456"
xpack.graph.enabled : true
xpack.ml.enabled : true
xpack.monitoring.enabled : true
xpack.reporting.enabled : true
xpack.security.enabled : true
xpack.watcher.enabled : true

docker run -d --name kibana --net tx -p 5601:5601 -v  /home/kibana/kibana.yml:/usr/share/kibana/config/kibana.yml kibana:6.7.1