在工作中,需要把mysql中的数据写入到es中进行分析;

官方文档:https://www.elastic.co/guide/en/logstash/6.3/plugins-inputs-jdbc.html

下面是配置方法:

input {jdbc {#数据库驱动路径jdbc_driver_library => "/data/mysql-connector-java-5.1.41-bin.jar"jdbc_driver_class => "com.mysql.jdbc.Driver"#数据库连接相关配置jdbc_connection_string => "jdbc:mysql://10.10.10.10:3306/test"jdbc_user => "root"jdbc_password => "123456"#任务计划,多久执行一次,在此每5分钟执行一次schedule =>"*/5 * * * *"#启用追踪,如果为true,则需要指定tracking_column,默认是timestampuse_column_value => true#指定追踪的字段,在此我设置的追踪的字段为idtracking_column => id#是否将字段名称转小写,当字段已经为小写时,不用此项lowercase_column_names => false#追踪字段的类型,目前只有数字(numeric)和时间类型(timestamp),默认是数字类型tracking_column_type => "numeric"#记录最后一次运行的结果record_last_run => true#上面运行结果的保存位置last_run_metadata_path => "/data/jdbc-position.txt"#执行的语句,也可以通过statement_filepath指定sql的文件statement => "SELECT * FROM student where id > :sql_last_value"#statement_filepath => "/data/test.sql"}
}
filter {json {source => "message"remove_field => ["message"]}
}
output {#输出到控制台进行调试,也可以写到kafka或者es中stdout { codec => rubydebug }
}

基于binlog的同步方案:

1.go-mysql-elasticsearch

2.maxwell

转载于:https://blog.51cto.com/liuzhengwei521/2325388

logstash增量读取mysql中的数据到es中相关推荐

  1. MySQL数据库数据导入ES中

    需要安装 mysql数据导入ES中,用到的有logstash,ES,mysql的连接包.链接:https://pan.baidu.com/s/1xopMMUtPir12zrQfYcwBZg  提取码: ...

  2. 读取mysql数据库的数据,转为json格式

    # coding=utf-8 ''' Created on 2016-10-26 @author: Jennifer Project:读取mysql数据库的数据,转为json格式 ''' import ...

  3. python读取mysql中表内数据_Python读取MySQL表数据的方法介绍

    这篇文章主要为大家详细介绍了Python如何读取MySQL数据库表数据,具有一定的参考价值,感兴趣的小伙伴们可以参考一下 本文实例为大家分享了Python读取MySQL数据库表数据的具体代码,供大家参 ...

  4. 在asp.net中如何用javascript读取本地Xml中的数据到网页中的文本框?

    在asp.net中如何用javascript读取本地Xml中的数据到网页中的文本框? 转载于:https://www.cnblogs.com/dynasty/archive/2005/08/18/21 ...

  5. python提取数据库数据_Python如何读取MySQL数据库表数据

    本文实例为大家分享了Python读取MySQL数据库表数据的具体代码,供大家参考,具体内容如下 环境:Python 3.6 ,Window 64bit 目的:从MySQL数据库读取目标表数据,并处理 ...

  6. mysql status关键字 数据表设计中慎重使用

    mysql status关键字  数据表设计中慎重使用 转载于:https://www.cnblogs.com/toSeeMyDream/p/5574894.html

  7. matlab读取excel表作图,读取Excel表格数据进行绘图-如何将excel表格中大量数据导入matlab中并作图...

    matlab 读取excel时间数据并绘图 没看懂你的格式是什么意思, 不过我一般读取excel都用xlsread函数,你也可以试一试 [a,b,c]=xlsresd('data.xls');%r如果 ...

  8. 最佳实践:MySQL CDC 同步数据到 ES

    作者:于乐,腾讯 CSIG 工程师 一. 方案描述 1.1 概述 在线教育是一种利用大数据.人工智能等新型互联网技术与传统教育行业相结合的新型教育方式.发展在线教育可以更好的构建网络化.数字化.个性化 ...

  9. 25 Redis的缓存中的数据和数据库中的不一致问题

    25 Redis的缓存中的数据和数据库中的不一致问题 前言 一.缓存和数据库的数据不一致是如何发生的? 二.解决Redis 和数据库数据不一致的方法 总结 前言 Redis 缓存经常会遇到有 4 个方 ...

最新文章

  1. Python3.8.5最新版安装教程(含老版本卸载教程)
  2. 基于pytorch量化感知训练(mnist分类)--浮点训练vs多bit后量化vs多bit量化感知训练效果对比
  3. VUE 动态绑定class
  4. linux 在执行命令过程中,反单引号(`)这个符号代表的意义为何?
  5. 树莓派 linux0.12,12 个可替代树莓派的单板机
  6. java系统时间怎么获取,java目前系统时间的获取
  7. 不定方程求解c语言_事业单位考试备考之数量关系:不定方程的求解
  8. python升级pip在哪儿打开_Linux下升级python和安装pip的详解
  9. VS2010中 C++创建DLL图解
  10. 在命令行启动vscode
  11. 【数据结构笔记33】C实现:希尔排序、增量序列
  12. 7万硕士、21万本科生在送外卖,是自愿还是工作难找无奈之举?
  13. C# 如何遍历删除某个控件上的所有子控件
  14. a标签增加onclick事件提示未定义function
  15. PHP 模拟库存出库商品
  16. 德标螺纹规格对照表_德标等螺纹对照表.doc
  17. iTween的用法总结
  18. 微信公众号模板消息(带流程图)
  19. 从 Sentence-BERT 谈句子表征
  20. MySQL高可用MMM

热门文章

  1. SQLite指南(1) -- SQLite的特性
  2. udp linux 获取本机ip
  3. C中的预编译宏定义-转
  4. [Java] 蓝桥杯ALGO-48 算法训练 关联矩阵
  5. docker与虚拟机性能比较
  6. golang基础-WaitGroup、kafka消费者
  7. JSONObject put,accumulate,element的区别
  8. IntelliJ 通过 Cloud Toolkit 登陆远程服务器终端 Terminal
  9. Linux 进程间通信 --- 信号通信 --- signal --- signal(SIGINT, my_func); --- 按键驱动异步通知(转)...
  10. Vc控件用法总结之List Control