Neo4j订阅Python中的数据库更改

f45qwnt8  于 2022-11-05  发布在  Python
关注(0)|答案(1)|浏览(139)

有两个微服务,一个使用条目队列将数据插入数据库,另一个进行一些复杂的计算,并基于该计算创建节点之间的关系。
我不想在第一个微服务中使用REST API、WebSocket等调用第二个微服务,而只想在第二个微服务中订阅数据库更改。Python中是否有插件、库等可以订阅neo4j数据库更改?

vx6bjr1n

vx6bjr1n1#

Neo4j Streams提供了Change Data Capture功能,可以将数据库的更改流到Kafka. https://neo4j.com/labs/kafka/4.0/producer/。如果您不想使用Kafka,可以选择使用APOC触发器,但是它们不如Kafka IMO. https://neo4j.com/labs/apoc/4.1/background-operations/triggers/成熟。但是,您可以选择非常具体地监听哪些更改。下面是一个根据触发器执行请求的示例:但您可能会在某处发送POST请求:https://tbgraph.wordpress.com/2017/03/07/neo4j-apoc-triggers-and-web-apis/

相关问题