Insert/update 使用 Couchbase 的 neo4j 文档

Insert/update docs in neo4j using Couchbase

我想 insert/update Couchbase 中的文档应该自动 inserted/updated 到 neo4j 数据库。他们有任何插件或软件可以做同样的事情吗?我怎样才能实现这个功能?

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

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

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

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

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

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

您还可以使用 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 具有低于 1 毫秒的性能并且支持 KeepAlive 12 个物理内核系统每秒可以将大约 40K 插入(或更新)从 Couchbase 流式传输到您的 Neo4j 实例。