Windows环境安装Logstash和Logstashinputjdbc

本文为 Windows 环境下的相关安装示例，适用于需要用 Logstash 和 Logstash-input-jdbc 将数据从数据库导入到 Elasticsearch 中的场景。

安装步骤

0. 安装 JDK 8 及 Elasticsearch

安装 JDK8 并配置 JAVA_HOME 环境变量；
安装 Elasticsearch 并启动；

1. 安装 Logstash

1.1 下载与你的 Elasticsearch 版本对应的 Logstash 版本

Logstash 官方下载地址

1.2 解压到本地路径

如:“D:Serverlogstash-6.8.0”

1.3 启动与验证

打开 CMD 命令行，切换到 logstash 安装路径下的 bin 目录，执行：

logstash -e "input {stdin {} } output {stdout {} }"

正常可以看到如图打印启动成功的信息。

可以输入测试内容，如“hello world”进一步验证。

2. 安装 Logstash-input-jdbc 插件

CMD 命令行切换到 bin 目录，执行以下命令安装 Logstash-input-jdbc 插件：

logstash-plugin install logstash-input-jdbc

安装正常将打印成功信息。

3. 验证 Logstash-input-jdbc

3.1 以 MySQL 为例，下载驱动 jar 到本地目录（此处以 logstash-6.8.0test 路径为例）

3.2 写测试的 conf 文件（如 test.conf）

input {stdin {}
  jdbc {
  jdbc_connection_string => "jdbc:mysql://localhost:3306/example"
  jdbc_user => "dbuser"
  jdbc_password => "123456"
  jdbc_driver_library => "../test/mysql-connector-java-5.1.47.jar"
  jdbc_driver_class => "com.mysql.jdbc.Driver"
  statement => "SELECT * FROM user"
  type => "test"
  }
}
output {
  elasticsearch {
    hosts => "localhost:9200"
    index => "world"
    document_id => "%{id}"
  }
  stdout {codec => json_lines}
}

3.3 运行测试 conf

logstash -f ../test/test.conf

你将会看到 JDBC 的查询结果信息

---

diboot 简单高效的轻代码开发框架