如何定期調用Logstash？

Question

我們使用Logstash從數據庫讀取新數據並將其發送到Elasticsearch。我們希望這種情況會定期發生，例如每分鐘一次。我們如何定期啓動Logstash？在Linux上做這件事的最佳做法是什麼？

Answer 1

您可以使用jdbc輸入的schedule參數。在你的情況，因爲你想運行此的每一分鐘，你會使用以下模式*/1 * * * *：

jdbc { 
    jdbc_driver_library => "/Users/logstash/mysql-connector-java-5.1.39-bin.jar" 
    jdbc_driver_class => "com.mysql.jdbc.Driver" 
    jdbc_connection_string => "jdbc:mysql://localhost:3306/database_name" 
    jdbc_user => "root" 
    jdbc_password => "password" 
    schedule => "*/1 * * * *"    <--- schedule for running every minute 
    statement => "select * from table1" 
    type => "table1" 
    }