通过Flink实时更新Dgraph

Question

我正在寻找一个低延迟的图形数据库，它允许深入查询，同时实时更新。是否有可能通过Flink进程实时更新Dgraph ?我想验证一个想法如下:

1. Kafka中的读流传递给Flink创建数据表/图

2. 将数据Table/Graph与边/顶点属性一起传递给Dgraph

3. 实时更新Dgraph(边/顶点属性)

4. 复制/提升最新版本的Dgraph到Flink执行计算(定期)

如果不可能:Dgraph是基于RocksDB的，有人知道数据是否可以通过RocksDB传递给Dgraph吗?

Answer 1

你所描述的听起来直截了当，Dgraph应该能够做这些操作。是否关注高吞吐量，即Dgraph是否能够承担Flink抛出的突变和查询负载?

您在这里可能遇到的主要问题是，数据需要转换为RDF格式以进行更改，并且查询需要使用我们使用的类似graphql的格式。

有关更多文档，您可以查看我们的wiki: https://wiki.dgraph.io/Main_Page

同样，很高兴理解你的具体用例，并在这里给出更详细的答案:https://discuss.dgraph.io