Logstash写数据到Mysql logstash怎么用

bigegpt 2024-10-12 05:50 9 浏览

准备工作

JDK -1.8+
Logstash -5.6.4（版本随意看你心情）

第一步，去官网下载Logstash安装包，并解压。

第二步，安装目录执行install，当看到successful恭喜你成功了。

logstash-plugin install logstash-output-jdbc

第三步，Mysql创建测试表

#建表语句
CREATE TABLE `student` (
`age` INT(10) NULL,
`name` VARCHAR(50) NULL
)
COLLATE='utf8mb4_general_ci'
ENGINE=InnoDB;

第四步，配置Logstash的conf。

读取就不在演示了，不是重点，以命令行方式代替。

input {
 #命令行输入
 stdin{}
}
filter{
 grok {
	#简单的正则匹配
 match => { "message" => "(?<age>\S+) (?<name>\S+)"}
 } 
}
output {
 stdout{
 codec=>rubydebug{}
 }
 jdbc {
 driver_class => "com.mysql.jdbc.Driver"
 connection_string => "jdbc:mysql://127.0.0.1:3306/test?user=root&password="
 statement => [ "INSERT INTO student (name, age) VALUES(?, ?)", "name", "age" ]
 }
}

第五步启动

logstash -f ../config/mysql.conf

仔细观察，原来是没有驱动jar包，去官网下载支持一下，mysql-connector-java

重新配置下conf

jdbc {
	#指定jar包路径
 driver_jar_path => "E:/logstash-6.5.4/lib/mysql-connector-java-5.1.47-bin.jar"
 driver_class => "com.mysql.jdbc.Driver"
 connection_string => "jdbc:mysql://127.0.0.1:3306/test?user=root&password="
 statement => [ "INSERT INTO student (name, age) VALUES(?, ?)", "name", "age" ]
 }

看下数据库

至此，Logstash整合Mysql就结束了。

当然这只是一个简单的Demo

详细信息见插件官网：https://github.com/theangryangel/logstash-output-jdbc

mysql-connector-java下载

上一篇：Java实现在线SQL编程(完整版) java代码中怎样写sql语句
下一篇：安装MySQL 安装MySQL installer

Logstash写数据到Mysql logstash怎么用

准备工作

相关推荐

无缓存不行?例行升级的入门级阿斯加特AN2 SSD装机点评

Ceph运维手册(基于P版本)

Docker 命令大全（docker命令大全记录表）

替代Docker build的Buildah简单介绍

Docker Desktop安装使用指南:零基础教程

Tensorflow分类loss函数总结 tensorflow绘制loss曲线

R语言学习笔记(七) -离散型数据的模型预测2

服务器硬件RAID性能横评(2)（服务器常用raid技术）

Python教程:第9篇字符串基本操作

k8s中三种POD调度策略介绍 k8s pod间调用

Logstash写数据到Mysql logstash怎么用

准备工作

相关推荐

无缓存不行?例行升级的入门级阿斯加特AN2 SSD装机点评

Ceph运维手册(基于P版本)

Docker 命令大全（docker命令大全记录表）

替代Docker build的Buildah简单介绍

Docker Desktop安装使用指南:零基础教程

Tensorflow分类loss函数总结 tensorflow绘制loss曲线

R语言学习笔记(七) -离散型数据的模型预测2

服务器硬件RAID性能横评(2)（服务器常用raid技术）

Python教程:第9篇 字符串基本操作

k8s中三种POD调度策略介绍 k8s pod间调用

Python教程:第9篇字符串基本操作