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