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



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

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

我读过这个博客https://dzone.com/articles/couchbase-amp-jdbc-integrations-for-neo4j-3x但我对Neo4jJSON Loader不太清楚,请指导我。

您还可以使用Couchbase事件服务,它将响应任何突变并触发JavaScript代码片段。提到https://docs.couchbase.com/server/current/eventing/eventing-overview.html

现在,您可能想要使用类似于这个scriptlet示例中的代码的东西:https://docs.couchbase.com/server/current/eventing/eventing-handler-curl-post.html假设Neo4j REST API具有低于1ms的性能并支持KeepAlive,则12个物理核心系统可以每秒从Couchbase向Neo4j实例流式传输约40K个插入(或更新(。

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

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

从那里,你可以阅读kafka主题,以便将数据导入Neo4j:

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

最新更新