Logstashを実行して、RDBMSからESにデータを同期させる方法を教えてください。

Question

私はELKスタックの完全な初心者ですので、私の無知を許してください。私はデータベースからElasticsearchにデータを送信するためにLogstashを取得することができましたが、転送が完了すると終了します。それを同期させて維持するにはどうすればいいですか？おかげ

Answer 1

あなたjdbc入力でscheduleを指定する必要があります。

以下schedule（* * * * *）分ごとに実行して、データベースからレコードを選択し、最後の時間が経過した後に更新されたレコードを選択しますクエリが実行されました。 updatedタイムスタンプフィールドの名前が異なる場合は、自分のケースに合わせて自由に調整してください。

input { 
    jdbc { 
    jdbc_driver_library => "mysql-connector-java-5.1.36-bin.jar" 
    jdbc_driver_class => "com.mysql.jdbc.Driver" 
    jdbc_connection_string => "jdbc:mysql://localhost:3306/mydb" 
    jdbc_user => "mysql" 
    parameters => { "some_field" => "value" } 
    schedule => "* * * * *" 
    statement => "SELECT * from songs WHERE some_field = :some_field AND updated > :sql_last_value" 
    } 
}