У меня проблема с подключением моей SQL базы данных сервера к Elasticsearch (7.6.1). Я уже установил ElasticSearch и Kibana (7.6.1). Теперь я хочу добавить свои данные из базы данных, используя logsta sh. Я написал файл конфигурации:
input {
jdbc {
jdbc_connection_string => "jdbc: sqlserver: // *Servername* ; databaseName = Northwind; IntegratedSecurity = true;"
jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
jdbc_user => "xxx"
statement => "SELECT * FROM Orders" } }
output {
elasticsearch {
hosts => [ "localhost:9200" ]
index => "cs_users" } }
Если я хочу запустить logsta sh в моей командной строке: bin\logstash -f sql.conf я получаю следующую ошибку:
[2020-03-26T12:00:00,132][ERROR][logstash.inputs.jdbc ][main] Unable to connect to database. Tried 1 times {:error_message=>"Java::JavaSql::SQLException: No suitable driver found for jdbc: sqlserver: // *Servername* ; databaseName = Northwind; IntegratedSecurity = true;"}
[2020-03-26T12:00:00,136][ERROR][logstash.javapipeline ][main] A plugin had an unrecoverable error. Will restart this plugin.
Pipeline_id:main
Plugin: <LogStash::Inputs::Jdbc jdbc_user=>"xxx", statement=>"SELECT * FROM Orders", jdbc_connection_string=>"jdbc: sqlserver: // *Servername* ; databaseName = Northwind; IntegratedSecurity = true;", id=>"a34b810d54e54e069edfecbf1aa4c0746658f78ebacd9fbea9b3f1b16e5c8c30", jdbc_driver_class=>"com.microsoft.sqlserver.jdbc.SQLServerDriver", enable_metric=>true, codec=><LogStash::Codecs::Plain id=>"plain_29cd1ad9-725b-4b4c-94b8-7f926a7cff03", enable_metric=>true, charset=>"UTF-8">, jdbc_paging_enabled=>false, jdbc_page_size=>100000, jdbc_validate_connection=>false, jdbc_validation_timeout=>3600, jdbc_pool_timeout=>5, sql_log_level=>"info", connection_retry_attempts=>1, connection_retry_attempts_wait_time=>0.5, plugin_timezone=>"utc", last_run_metadata_path=>"C:\\Users\\cca/.logstash_jdbc_last_run", use_column_value=>false, tracking_column_type=>"numeric", clean_run=>false, record_last_run=>true, lowercase_column_names=>true, use_prepared_statements=>false>
Error: Java::JavaSql::SQLException: No suitable driver found for jdbc: sqlserver: // *Servername* ; databaseName = Northwind; IntegratedSecurity = true;
Exception: Sequel::DatabaseConnectionError
Stack: java.sql.DriverManager.getConnection(java/sql/DriverManager.java:689)
java.sql.DriverManager.getConnection(java/sql/DriverManager.java:270)
java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:498)
org.jruby.javasupport.JavaMethod.invokeDirectWithExceptionHandling(org/jruby/javasupport/JavaMethod.java:426)
org.jruby.javasupport.JavaMethod.invokeStaticDirect(org/jruby/javasupport/JavaMethod.java:358)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.adapters.jdbc.connect(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/adapters/jdbc.rb:215)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.connection_pool.make_new(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/connection_pool.rb:122)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.connection_pool.threaded.assign_connection(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/connection_pool/threaded.rb:209)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.connection_pool.threaded.acquire(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/connection_pool/threaded.rb:139)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.connection_pool.threaded.hold(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/connection_pool/threaded.rb:91)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.database.connecting.synchronize(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/database/connecting.rb:270)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.database.connecting.test_connection(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/database/connecting.rb:279)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.database.connecting.connect(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/database/connecting.rb:58)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.sequel_minus_5_dot_29_dot_0.lib.sequel.core.connect(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/sequel-5.29.0/lib/sequel/core.rb:121)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_jdbc_minus_5_dot_0_dot_1.lib.logstash.plugin_mixins.jdbc.jdbc.jdbc_connect(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/logstash-integration-jdbc-5.0.1/lib/logstash/plugin_mixins/jdbc/jdbc.rb:119)
org.jruby.RubyKernel.loop(org/jruby/RubyKernel.java:1446)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_jdbc_minus_5_dot_0_dot_1.lib.logstash.plugin_mixins.jdbc.jdbc.jdbc_connect(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/logstash-integration-jdbc-5.0.1/lib/logstash/plugin_mixins/jdbc/jdbc.rb:116)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_jdbc_minus_5_dot_0_dot_1.lib.logstash.plugin_mixins.jdbc.jdbc.open_jdbc_connection(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/logstash-integration-jdbc-5.0.1/lib/logstash/plugin_mixins/jdbc/jdbc.rb:194)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_jdbc_minus_5_dot_0_dot_1.lib.logstash.plugin_mixins.jdbc.jdbc.execute_statement(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/logstash-integration-jdbc-5.0.1/lib/logstash/plugin_mixins/jdbc/jdbc.rb:253)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_jdbc_minus_5_dot_0_dot_1.lib.logstash.inputs.jdbc.execute_query(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/logstash-integration-jdbc-5.0.1/lib/logstash/inputs/jdbc.rb:310)
C_3a_.logstash_minus_7_dot_6_dot_1.vendor.bundle.jruby.$2_dot_5_dot_0.gems.logstash_minus_integration_minus_jdbc_minus_5_dot_0_dot_1.lib.logstash.inputs.jdbc.run(C:/logstash-7.6.1/vendor/bundle/jruby/2.5.0/gems/logstash-integration-jdbc-5.0.1/lib/logstash/inputs/jdbc.rb:282)
C_3a_.logstash_minus_7_dot_6_dot_1.logstash_minus_core.lib.logstash.java_pipeline.inputworker(C:/logstash-7.6.1/logstash-core/lib/logstash/java_pipeline.rb:328)
C_3a_.logstash_minus_7_dot_6_dot_1.logstash_minus_core.lib.logstash.java_pipeline.RUBY$method$inputworker$0$__VARARGS__(C_3a_/logstash_minus_7_dot_6_dot_1/logstash_minus_core/lib/logstash/C:/logstash-7.6.1/logstash-core/lib/logstash/java_pipeline.rb)
C_3a_.logstash_minus_7_dot_6_dot_1.logstash_minus_core.lib.logstash.java_pipeline.start_input(C:/logstash-7.6.1/logstash-core/lib/logstash/java_pipeline.rb:320)
org.jruby.RubyProc.call(org/jruby/RubyProc.java:274)
java.lang.Thread.run(java/lang/Thread.java:748)
Я пробовал много вещи, но не получили решения. Пожалуйста, помогите мне. Спасибо!