1.

根據截圖可知：ouput是輸出到elasticsearch,具體的IP.你可以自己設定。我設定的是本地環境。也就是localhost：9200.

input{繫結應用以及埠，beats{}詳細的去解析一下。

}先百度學習一下beats{}這個具體指的是什麼東西。

方法：

查閱官方文件：

官網連線如下：

https://www.elastic.co/guide/en/logstash/current/introduction.html

具體輸入的內部構造原理如下：

處理大資料的輸入集如下操作：

注意一點logsash.conf也就是配置檔案必須是ANSI檔案格式的，不然會報錯。

報錯的錯誤如下：

ch::HttpClient::Pool::HostUnreachableError, :error=>"Elasticsearch Unreachable: [http://localhost:9200/][Manticore::SocketException] Connection refused: connect"}
Tue Nov 13 11:28:00 CST 2018 WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification.
[2018-11-13T11:28:00,194][INFO ][logstash.inputs.jdbc     ] (0.001014s) SELECT version()
[2018-11-13T11:28:00,197][INFO ][logstash.inputs.jdbc     ] (0.000978s) SELECT version()
[2018-11-13T11:28:00,200][ERROR][logstash.inputs.jdbc     ] Java::ComMysqlJdbcExceptionsJdbc4::MySQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near ';) AS `t1` LIMIT 1' at line 1: SELECT count(*) AS `count` FROM (SELECT * from areacheckdaily;) AS `t1` LIMIT 1

logstash的配置檔案預設檔案編碼必須要注意。