如题:
现在 使用logstash-input-jdbc 插件 在logstash 中同步mysql 重的数据,遇到删除时,目前我时在业务中 mysql 和 es 两边进行删除的,没有其他更好的办法吗,有想过修改mysql 的日志配置,但是目前更改的话风险比较大,还有其他比较好的方法吗?
现在 使用logstash-input-jdbc 插件 在logstash 中同步mysql 重的数据,遇到删除时,目前我时在业务中 mysql 和 es 两边进行删除的,没有其他更好的办法吗,有想过修改mysql 的日志配置,但是目前更改的话风险比较大,还有其他比较好的方法吗?
3 个回复
rochy - rochy_he
赞同来自:
最后调用 delete_by_query 执行 dsl 即可
langhua81
赞同来自:
我不是很理解,你看说的对不对,你说将删除的sql 转成 select .. 意思是说,,将要删除的id 用select 语句查出来,然后,使用es 提供的sql 转成dsl ? 不知道什么意思,,
laoyang360 - 《一本书讲透Elasticsearch》作者,Elastic认证工程师 [死磕Elasitcsearch]知识星球地址:http://t.cn/RmwM3N9;微信公众号:铭毅天下; 博客:https://elastic.blog.csdn.net
赞同来自: