Logstash чтения данных SQL Server в режиме реального времени - PullRequest
0 голосов
/ 07 февраля 2019

Можно ли как-нибудь настроить logstash, чтобы он автоматически собирал дельта-записи в реальном времени.Если нет, то есть ли плагин / инструмент с открытым исходным кодом для этого?Спасибо за помощь.

1 Ответ

0 голосов
/ 07 февраля 2019

Попробуйте приведенную ниже конфигурацию для сервера MSSQL.Вы должны запланировать это, как показано ниже, добавив период расписания, оператор, который будет запрашивать данные из вашей базы данных

input {
  jdbc { 
    jdbc_connection_string => "jdbc:sqlserver://localhost:1433;databaseName=test"
    # The user we wish to execute our statement as
    jdbc_user => "sa"
    jdbc_password => "sasa"
    # The path to our downloaded jdbc driver
    jdbc_driver_library => "C:\Users\abhijitb\.m2\repository\com\microsoft\sqlserver\mssql-jdbc\6.2.2.jre8\mssql-jdbc-6.2.2.jre8.jar"
    jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
    #clean_run => true
    schedule => "* * * * *"
    #query
    statement => "SELECT * FROM Student where studentid > :sql_last_value"
    use_column_value => true
    tracking_column => "studentid"
    }
}

output {
  #stdout { codec => json_lines }
  elasticsearch {
  "hosts" => "localhost:9200"
  "index" => "student"
  "document_type" => "data"
  "document_id" => "%{studentid}"
  }
}
...