Вы можете использовать logstash для этого, где пример файла конфигурации для отправки данных из POSTGRES вasticsearch, как показано ниже. Вы можете перейти по этой ссылке для подробного урока
input {
jdbc {
jdbc_connection_string => "jdbc:postgresql://:5432/"
jdbc_user => "<my-username>"
jdbc_password => "<my-password>"
jdbc_driver_library => "///postgresql-42.1.4.jar"
jdbc_driver_class => "org.postgresql.Driver"
statement => "SELECT * from contact"
}
}
output {
elasticsearch {
index => "contact"
hosts => ["localhost:9200"]
}
}