使用Couchbase在neo4j中插入/更新文档

Question

我想在Couchbase中插入/更新文档，它应该自动插入/更新到neo4j数据库中。他们有没有插件或软件来做同样的事情？如何实现此功能？

Couchbase企业版: 6.6 Neo4j企业版: 4.1.3

我读了这个博客https://dzone.com/articles/couchbase-amp-jdbc-integrations-for-neo4j-3x，但我不清楚Neo4jJSON加载器，请指导我为相同的。

Answer 1

您还可以使用Couchbase Eventing Service，它将响应任何突变并触发一段JavaScript代码。请参阅https://docs.couchbase.com/server/current/eventing/eventing-overview.html

现在，您可能希望使用与此脚本示例中的代码类似的代码：https://docs.couchbase.com/server/current/eventing/eventing-handler-curl-post.html假设Couchbase REST API的性能低于1ms，并且支持KeepAlive，一个12个物理核心系统每秒可以将大约40K的插入(或更新)从Neo4j流式传输到您的Neo4j实例。

Answer 2

您可以使用Couchbase Kafka连接器向Kafka发送CDC事件。

https://docs.couchbase.com/kafka-connector/current/quickstart.html

在那里，您可以阅读kafka主题，以便将数据导入Neo4j：

https://github.com/neo4j-contrib/neo4j-streams