Elasticsearch logstsh测试数据新增和修改

摘要:
查看elasticsearch的数据可以看到,ES中已经同步了MySql中的数据修改。补充问题:1、Logstash时间不是标准时间2、Logstash与数据库时间相差8小时修改conf默认时区为上海cd/usr/local/logstash-7.4.2/syncvilogstash-db-sync.conf2、将新增的数据同步到ES中增加id为4的数据logstash日志es中查看数据说明新增的数据已经同步到了ES中。只能假删,这样就能同步到ES中。

1、将MySql中修改的数据同步到ES中

修改mysql中的数据

Elasticsearch logstsh测试数据新增和修改第1张

logstash中看到日志,修改的数据已经同步。

Elasticsearch logstsh测试数据新增和修改第2张

查看elasticsearch的数据

Elasticsearch logstsh测试数据新增和修改第3张

可以看到,ES中已经同步了MySql中的数据修改。

补充问题:

1、Logstash时间不是标准时间

2、Logstash与数据库时间相差8小时

修改conf默认时区为上海

cd /usr/local/logstash-7.4.2/sync

vilogstash-db-sync.conf

Elasticsearch logstsh测试数据新增和修改第4张

2、将新增的数据同步到ES中

增加id为4的数据

Elasticsearch logstsh测试数据新增和修改第5张

logstash日志

Elasticsearch logstsh测试数据新增和修改第6张

es中查看数据

Elasticsearch logstsh测试数据新增和修改第7张

说明新增的数据已经同步到了ES中。

注意: 数据中删除数据,是不会同步到ES中的。只能假删(将状态改为已删除),这样就能同步到ES中。

免责声明:文章转载自《Elasticsearch logstsh测试数据新增和修改》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇深入浅出 妙用Javascript中apply、call、bindmac更新node,npm版本下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

监控elasticsearch集群方案

1、监控组件 X-Pack是一个Elastic Stack的扩展,包括安全,警报,监控,报告和图形等功能。 es5.x以后可以安装X-Pack,5.x以前需要安装多个组件(Shield,Watcher,Marvel,Graph,Reporting)(这些组件现已集成到X-Pack中),sense也已集成到kibana中。 6.x以后的版本无需单独安装X-P...

mysql 把备份数据文件还原后乱码处理方法

1、检测创建数据库是否设置编码格式     create database dbname DEFAULT CHARSET=utf8; 2、检测数据库备份文件中的首行是否存在编码设置    /*!40101 SET NAMES utf8 */;...

mac单机 k8s minikube ELK yaml 详细配置 踩坑

1.准备工作 安装minikube, 安装kubectl(不再赘述, 自行查找) 启动minikube minikube start image-mirror-country='cn' --registry-mirror=https://registry.docker-cn.com --memory=4096 --image-repository=re...

【Oracle】给clob字段插入数据

// 插入 //OracleCommand cmd = "insertInto into GIS_PolygonPoint(PCode,PointColl) values('140134', :var)"; // 修改 //OracleCommand cmd = new OracleCommand("update yd_line set coord=:co...

MySQL数据库运维的五大指标

如何评价一个公司数据库运维水平的高低?用什么来进行横向与纵向对比?自动化平台建设的目标是什么?必须有相应的指标体系来指导,此指标体系必须满足以下条件:• 可以用数字来测算和衡量• 最终指标,而不是中间指标比如有时DBA会关注数据库的吞吐量,但吞吐量越高不能代表数据库提供的服务质量越好,开发人员关心这个指标的原因也是因为担心过高的吞吐量会影响响应时间或者造成...

Mysql中使用JDBC流式查询避免数据量过大导致OOM

一、前言 java 中MySQL JDBC 封装了流式查询操作,通过设置几个参数,就可以避免一次返回数据过大导致 OOM。 二、如何使用 2.1 之前查询 public void selectData(String sqlCmd) throwsSQLException { validate(sqlCmd); Connection con...