1.下载并安装 Maven 非必要
- wget http://repos.fedorapeople.org/repos/dchen/apache-maven/epel-apache-maven.repo -O /etc/yum.repos.d/epel-apache-maven.repo
- sed -i s/\$releasever/6/g /etc/yum.repos.d/epel-apache-maven.repo
- yum install maven
2.安装 Microsoft JDBC Driver 6.2 for SQL Server
a).通过 Maven
- com.microsoft.sqlserver
- mssql-jdbc
- 6.2.1.jre8
b).直接下载，重命名为 jdbc-6.2.1.jre8.jar
- wget http://search.maven.org/remotecontent?filepath=com/microsoft/sqlserver/mssql-jdbc/6.2.1.jre8/mssql-jdbc-6.2.1.jre8.jar
3.创建 logstash 配置文件并保存到/etc/logstash/conf.d
- input {
- jdbc {
- jdbc_driver_library => "/usr/share/logstash/jdbc-6.2.1.jre8.jar"
- jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
- jdbc_connection_string => "jdbc:sqlserver://192.168.6.1:1433;databaseName=Logstash;integratedSecurity=false;user=***;password=***;"
- jdbc_user => "***"
- jdbc_password => "***"
- statement => "SELECT * FROM [Logstash].[dbo].[base]"
- }
- }
- output {
- elasticsearch {
- hosts => "192.168.6.128:9200"
- index => "logstash"
- document_type =>"dbo"
- document_id => "%{id}"
- }
- stdout { codec=> rubydebug }
- }
4.重新启动 logstash
- systemctl restart logstash.service
5.设置数据库，并插入测试数据
- CREATE TABLE [dbo].[base]([id] [int] IDENTITY(1,1) NOT NULL,[name] [nvarchar](50) NULL,create_time] [datetime] NULL,CONSTRAINT [PK_base] PRIMARY KEY CLUSTERED([id] ASC)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]) ON [PRIMARY]
- GO
- SET IDENTITY_INSERT [dbo].[base] ON
- INSERT [dbo].[base] ([id],[name],[create_time]) VALUES (1,NULL,NULL),(2,N'Hello',getdate()),(3,N'Hello1',getdate())
- GO
- SET IDENTITY_INSERT [dbo].[base] OFF
- GO
6.等待结果