Соединение Logstash 6.5 и asticsearch 6.5 с использованием SSL

Я пытаюсь подключить push-данные из MySQL к asticsearch, используя logstash через SSL. Elasticsearch и mysql находятся в облаке IBM. Файл конфигурации logstash настроен

input {
    jdbc {
        jdbc_validate_connection => true
        jdbc_connection_string => "jdbc:mysql://<host>:<port>/<schema>?autoReconnect=true&useSSL=false"
        jdbc_user => "test"
        jdbc_password => "pwd"
        jdbc_driver_library => "D:/mysql-connector-java-8.0.12/mysql-connector-java-8.0.12.jar"
        jdbc_driver_class => "Java::com.mysql.cj.jdbc.Driver"
        jdbc_paging_enabled => true
        jdbc_page_size => 25000
        type => "location"
        statement => "SELECT  ENTITY_NAME,
                            SECONDARY_ENTITY_NAME,
                                KEYWORD,
                                DESCRIPTION,
                                LATITUDE,
                                LONGITUDE,
                                MAP_URL,
                                SHORT_URL,
                                REF_URL,
                                LANGUAGES                           
                                FROM LOCATION"
    }

}
filter{
            mutate{
                rename => {
                "entity_name" => "ENTITY_NAME"
                "secondary_entity_name" => "SECONDARY_ENTITY_NAME"
                "keyword" => "KEYWORD"
                "description" => "DESCRIPTION"              
                "map_url" =>"MAP_URL"
                "short_url" => "SHORT_URL"
                "ref_url" =>"REF_URL"
                "languages"=>"LANGUAGES"

                 }



        }
        if [latitude] and [longitude]!="" {
        mutate {
            rename => {
                "latitude" => "[LAT_LON][lat]"
                "longitude" => "[LAT_LON][lon]"
            }
        }
    }





}       
output {
    elasticsearch {
        action=>"index" 
        hosts=>["https://<id>:<pwd>@<hostname>:<pot>/"]
        index=>"test_location"
        document_type=>"%{type}"
        ssl=>true
        ssl_certificate_verification=>true
        cacert=>"D:/Data/Logstash-ES-6.5-Mapping/ca_logstash.cer"
    }
    stdout {}
}

Я получаю ошибку как

[ОШИБКА][logstash.pipeline ] Ошибка регистрации плагина {:pipeline_id=>"main",:plugin=>"#",:error=>"Данные сертификата не найдены",:thread=>"#"}

Я знаю, что это не в состоянии получить данные сертификата. пытался дать точный путь, который тоже не работает?

Настройки конфигурации правильные?

0 ответов

Другие вопросы по тегам