如何同步Cassandra和Elasticsearch

Question

3

我正在寻找一种解决方案，即如何将Cassandra与Elasticsearch同步，即无论写入什么数据到Cassandra，都应该同时写入Elasticsearch。

- Manish Kumar

2个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Gudmundur Orn · Answer 1

一种方法是开发一个定时或循环运行的捕获过程，从Cassandra中读取“新”数据并将其发送到Elasticsearch。 “新”数据的定义取决于您的Cassandra模式和应用程序的插入/更新/删除模式。

- Deepak Panneerselvam · Answer 2

这可以实时完成，也可以作为单独的批处理过程。

当您根据检索模式/查询模式将数据传输到基于Cassandra的系统中时，请将数据索引到Elasticsearch中。

具有实时处理层（例如Strom）/分布式消息代理（如Kafka）以同步数据。

或定期从Cassandra查询数据，并将其作为单独的批处理作业注入到ES中。