JDBCでmysqlクエリを取得してelasticsearchに送信

Question

Good Moring、 MySQLデータベースからデータを取得してelasticsearchに送信しようとしていますので、木場にグラフを作成して表示できます。

私はこの設定でelasticsearch-JDBCプラグインを使用しています：

input { 
    jdbc { 
    jdbc_driver_library => "/home/USERNAME/mysql-connector-java-5.1.40/mysql-connector-java-5.1.40-bin.jar" 
    jdbc_driver_class => "com.mysql.jdbc.Driver" 
    jdbc_connection_string => "jdbc:mysql://localhost:3306/DB_NAME" 
    jdbc_user => "USER" 
    jdbc_password => "PASSWORD" 
    schedule => "* * * * *" 
    statement => "SELECT * from eps" 
    } 
} 

output { 
    elasticsearch { 
     hosts => ["localhost:9200"] 
     sniffing => false 
     index => "eps" 
     document_type => "eps" 
     document_id => "%{uid}" 
     } 
} 

と成功せず。 私は/var/log/logstash/logstash-plain.log で探していたとき、私はこのエラーを取得：

[2016-11-17T11:54:17,592][ERROR][logstash.agent   ] fetched an invalid config {:config=>"input {\n beats {\n port => 5044\n y\n }\n}\n\noutput {\n elasticsearch {\n hosts => [\"localhost:9200\"]\n manage_template => false\n index => \"%{[@metadata][beat]}-%{+YYYY.MM.dd}\"\n document_type => \"%{[@metadata][type]}\"\n }\n}\n\ninput {\n jdbc {\n jdbc_driver_library => \"/home/USERNAME/mysql-connector-java-5.1.40/mysql-connector-java-5.1.40-bin.jar\"\n jdbc_driver_class => \"com.mysql.jdbc.Driver\"\n jdbc_connection_string => \"jdbc:mysql://localhost:3306/DB_NAME\"\n jdbc_user => \"USER\"\n jdbc_password => \"PASSWORD\"\n schedule => \"* * * * *\"\n statement => \"SELECT * from eps\"\n }\n}\n\noutput {\n elasticsearch {\n  hosts => [\"localhost:9200\"]\n  sniffing => false\n  index => \"eps\"\n  document_type => \"eps\"\n  document_id => \"%{uid}\"\n  }\n}\n\n", :reason=>"Expected one of #, => at line 5, column 2 (byte 42) after input {\n beats {\n port => 5044\n y\n "} 

私が使用して新しいID名を作成しました：

curl -XPUT 'localhost:9200/river/my_jdbc_river/_meta' -d '{ 
>  "type" : "jdbc", 
>  "jdbc" : { 
>   "url" : "jdbc:mysql://localhost:3306/MY_DB", 
>   "user" : "USER", 
>   "password" : "PASSWORD", 
>   "sql" : "select * from eps" 
>  } 
> }' 

私が持っていますこの投稿のUSERNAMEとPASSWORDに変更されましたが、私は確信しました。そうではありませんが。

私が間違っていることを知っていますか？ ありがとう Idan

Answer 1

エラーメッセージは、あなたの設定が無効であると言います。エラーメッセージから

は、我々はこれを持っている：

input { 
    beats { 
    port => 5044 
    y 
    } 
} 

yがここには何の関係もありませんし、問題はそこから来ています。また、エラーメッセージの最後にもありました。