如何在 Neo4j 中自动匹配从 kafka 发送的事件

问题描述

我有一些事件从 Kafka 主题发送到现有的 Neo4j 数据库数据库已经有大约 4000 个标签和 11500 个关系。这些从 kafka 发送的事件应该自动匹配它们对应的节点。让我们说:

有 3 个节点代表产品 a 和产品 b。

kafka 主题将不同产品的状态发布到 neo4j: 产品 a:有货,产品 b:已屏蔽:产品 a:已屏蔽,产品 a:已发货

图表应该是:

(产品 A)------>(有货)----->(已屏蔽)---->(已发货)

(产品 B)------>(被屏蔽

我不知道如何解决这个问题。尽我所能,我可以将事件从 kafka 摄取到 neo4j,但之后我无法将它们与相应的产品相匹配。

非常感谢。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)