官方说river已经Deprecated了。https://www.elastic.co/blog/deprecating-rivers。 按照文中的说法,数据的同步可以采取两种方式: 1)使用客户端代码。 把elasticsearch数据的增删直接写到应用代码中,如这篇文章介绍的(http://david.pilato.fr/blog/2015/05/09/advanced-search-for-your-legacy...)。 但是文中也没有详细说如何解决数据的一致性问题,比如数据库正常运行、但是ES挂了的情况下,ES重启后数据库中的数据增删怎么反映到ES中。 2)使用Logstash。 结合input plugin(比如用JDBC输入)和output plugin(比如输出到elasticsearch)。 但是这种方法似乎只能同步在数据库中新增的数据,数据库中删除了的怎么同步我也不清楚。 我也正在找解决方案。
官方说river已经Deprecated了。https://www.elastic.co/blog/deprecating-rivers。
按照文中的说法,数据的同步可以采取两种方式:
1)使用客户端代码。
把elasticsearch数据的增删直接写到应用代码中,如这篇文章介绍的(http://david.pilato.fr/blog/2015/05/09/advanced-search-for-your-legacy...)。
但是文中也没有详细说如何解决数据的一致性问题,比如数据库正常运行、但是ES挂了的情况下,ES重启后数据库中的数据增删怎么反映到ES中。
2)使用Logstash。
结合input plugin(比如用JDBC输入)和output plugin(比如输出到elasticsearch)。
但是这种方法似乎只能同步在数据库中新增的数据,数据库中删除了的怎么同步我也不清楚。
我也正在找解决方案。