环境信息
canal version mysql version
问题描述
deployer从mysql同步数据到kafka上,然后借由logstash拉取数据后,在es上看到的是,所有数据都在message中,没有自动mapping。 有办法实现自动mapping吗?
原提问者GitHub用户wajika
可以通过配置logstash的filter插件来自动映射字段。
在你的logstash配置文件中,可以使用以下的filter插件示例:
filter { json { source => "message" } } 这个filter插件将会解析message字段中的json数据,并映射为es中的相应字段。如果json数据中包含了自定义字段,它们也将被自动映射到es中。
当然,如果您想要更详细的映射控制,您可以在filter插件中使用mutate、rename等其他插件来自定义映射。这些插件可以在logstash官方文档中找到。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。