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]}"
  }
}