Elasticsearch实例连接

HTTPS访问模式

input部分使用如下配置

input {
  elasticsearch {
    # Elasticsearch实例的访问地址。
    hosts => ["ip:9200","ip:9200","ip:9200"]
    # 配置查询的索引名,示例如下。
    index => "your_index"
    # 保留索引中的元数据。
    docinfo => true
    # 访问Elasticsearch实例的用户名和密码。
    user => "admin"
    password => "********"
    # https模式需要配置ssl => true。
    ssl => true
  }
}

output部分使用如下配置：

output{
  elasticsearch {
    # Elasticsearch实例的访问地址。
    hosts => ["ip:9200","ip:9200","ip:9200"]
    # 配置写入的索引名。
    index => "your_index"
    # 访问Elasticsearch实例的用户名和密码。
    user => "admin"
    password => "************"
    # 如果是Elasticsearch实例的迁移任务，可以选择该配置，用来保留元数据的id。
    document_id => "%{[@metadata][_id]}"
    # https模式需要配置ssl => true。
    ssl => true
  }
}                                                                                                                                                                                                                                                                                                                                                                                                            

HTTP访问模式

使用加装的Logstash访问Elasticsearch实例的配置相比HTTPS访问模式，只需要把input和output部分的`ssl => true`删除即可。示例配置如下：

input部分使用如下配置：

input {
  elasticsearch {
    # Elasticsearch实例的访问地址。
    hosts => ["ip:9200","ip:9200","ip:9200"]
    # 配置查询的索引名,示例如下。
    index => "your_index"
    # 保留索引中的元数据。
    docinfo => true
    # 访问Elasticsearch实例的用户名和密码。
    user => "admin"
    password => "********"
  }
}

output部分使用如下配置：

output{
  elasticsearch {
    # Elasticsearch实例的访问地址。
    hosts => ["ip:9200","ip:9200","ip:9200"]
    # 配置写入的索引名。
    index => "your_index"
    # 访问Elasticsearch实例的用户名和密码。
    user => "admin"
    password => "************"
    # 如果是Elasticsearch实例的迁移任务，可以选择该配置，用来保留元数据的id。
    document_id => "%{[@metadata][_id]}"
  }
}

请根据实际业务情况配置Logstash管道文件的input、filter及output的配置。

OpenSearch实例连接

HTTPS访问模式

input部分使用如下配置：

input {
  elasticsearch {
    # OpenSearch实例的访问地址，这里复用elasticsearch的input插件。
    hosts => ["ip:9200","ip:9200","ip:9200"]
    # 配置查询的索引名,示例如下。
    index => "your_index"
    # 保留索引中的元数据。
    docinfo => true
    # 访问OpenSearch实例的用户名和密码。
    user => "admin"
    password => "********"
    # https模式需要配置ssl => true。
    ssl => true
  }
}

output部分使用如下配置：

output{
  OpenSearch {
    # OpenSearch实例的访问地址。
    hosts => ["ip:9200","ip:9200","ip:9200"]
    # 配置写入的索引名。
    index => "your_index"
    # 访问OpenSearch实例的用户名和密码。
    user => "admin"
    password => "************"
    # 如果是OpenSearch实例的迁移任务，可以选择该配置，用来保留元数据的id。
    document_id => "%{[@metadata][_id]}"
    # https模式需要配置ssl => true。
    ssl => true
  }
}

HTTP访问模式

使用加装的Logstash访问OpenSearch实例的配置相比HTTPS访问模式，只需要把input和output部分的`ssl => true`删除即可。

input部分使用如下配置：

input {
  elasticsearch {
    # OpenSearch实例的访问地址，这里复用elasticsearch的input插件。
    hosts => ["ip:9200","ip:9200","ip:9200"]
    # 配置查询的索引名,示例如下。
    index => "your_index"
    # 保留索引中的元数据。
    docinfo => true
    # 访问OpenSearch实例的用户名和密码。
    user => "admin"
    password => "********"
  }
}

output部分使用如下配置：

output{
  OpenSearch {
    # OpenSearch实例的访问地址。
    hosts => ["ip:9200","ip:9200","ip:9200"]
    # 配置写入的索引名。
    index => "your_index"
    # 访问OpenSearch实例的用户名和密码。
    user => "admin"
    password => "************"
    # 如果是OpenSearch实例的迁移任务，可以选择该配置，用来保留元数据的id。
    document_id => "%{[@metadata][_id]}"
  }
}