linux - 如何定期调用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"
  }