elasticsearch - 如何以最小的延迟从Elasticsearch更新neo4j图形数据库？

Question

我有大量的Elastic Search索引会定期更新，我想将这些更新反射(reflect)在neo4j图形数据库中，以最小的延迟在Elastic Search中对项目建立索引并将其更新为Neo4j。
(同时，保持低水平的管理工作很重要:例如，我只想更新一个cypher语句来定义索引文档和图形之间的映射，所以一旦创建了索引，将工作限于将其数据添加到Neo4j)。
是否可以使用Elastic search watchers和triggers做到这一点？还是通过其他方式？
我知道Neo4j中APOC库的Elastic Search functions，但是我宁愿在更新时从Elastic Search中推送而不是从Neo4j中提取。 GraphAware也有一个extension，但它似乎主要针对Neo4j到ES的方向。

Answer 1

ElasticSearch触发器可以发布HTTP请求，而Neo4j具有HTTP Api，因此似乎可行:https://neo4j.com/docs/http-api/current/
如果要在生产中执行此操作，则可能会开发一种微服务，以侦听Webhook，并将数据存储到Neo4j中。这样，您可以引入重试策略以及日志错误(如果没有其他问题)。
经过一些研究后，您可以配置ElasticSearch以使用https://github.com/malike/elasticsearch-kafka-watch等工具将更新推送到Kafka，然后使用Neo4j Kafka Sink接收数据。