Wie kann ich Logstash laufen lassen, damit Daten von meinem RDBMS mit ES synchronisiert werden?

Question

Ich bin ein kompletter Neuling auf dem ELK-Stack, also entschuldige bitte meine Ignoranz. Ich konnte Logstash dazu bringen, Daten von meiner Datenbank an Elasticsearch zu senden, aber es wird beendet, sobald es mit der Übertragung fertig ist. Wie behalte ich es, damit es synchron bleibt? Dank

Answer 1

Sie benötigen einen schedule in Ihrem jdbc Eingabe angeben:

Die schedule unten (* * * * *) wird jede Minute ein und wählen Sie Datensätze aus Ihrer Datenbank ausführen und nur die Datensätze auswählen, die nach dem letzten Aufruf aktualisiert wurden, die Abfrage ausgeführt. Ihr updated Timestamp-Feld könnte anders benannt sein, Sie können es also ganz nach Ihrem Geschmack anpassen.

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