通过Logstash将ES数据迁移至阿里云ES Serverless

连接ECS服务器。

具体操作请参见 通过密码或密钥认证登录Linux实例 。

连接ECS服务器。

具体操作请参见 通过密码或密钥认证登录Linux实例 。

在config目录下，创建并打开Logstash配置文件。

cd logstash-7.10.2/config
sudo vi es2es_all.conf

参考以下配置，修改Logstash配置文件。

input{
    elasticsearch{
        # 源端ES地址。
        hosts =>  ["http://localhost:9200"]
        # 安全集群配置登录用户名密码。
        user => "xxxx"
        password => "xxxxxx"
        # 需要迁移的索引列表，多个索引以英文以逗号（,）分隔。
        index => ["kibana_sample_data_*"]
        # 以下三项保持默认即可，包含线程数和迁移数据大小和Logstash JVM配置相关。
        docinfo=>true
        slices => 5
        size => 5000
filter {
  # 去掉一些Logstash自己加的字段。
  mutate {
    remove_field => ["@timestamp", "@version"]
output{
    elasticsearch{
        # 目标端Serverless应用公网访问地址，可在应用详情页面获取。
        hosts => ["http://****.public.hangzhou.es-serverless.aliyuncs.com:9200"]
        # 应用的用户名和密码。
        user => "xxxx"
        password => "xxxxxx"
        # 目标端索引名称，以下配置表示索引与源端保持一致。
        index => "%{[@metadata][_index]}"
        # 目标端索引type，以下配置表示索引类型与源端保持一致。
        document_type => "%{[@metadata][_type]}"
        # 目标端数据的id，如果不需要保留原id，可以删除以下这行，删除后性能会更好。
        document_id => "%{[@metadata][_id]}"
        ilm_enabled => false
        manage_template => false
}

登录Elasticsearch Serverless应用的Kibana控制台。

具体操作，请参见 通过Kibana使用Serverless应用 。