首页 文章

通过Flink实时更新Dgraph

提问于
浏览
1

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

  • 在Kafka中读取流传递给Flink以创建数据表/图表

  • 将数据表/图表与边缘/顶点属性一起传递给Dgraph

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

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

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

1 回答

  • 3

    你所描述的听起来很直接,Dgraph应该能够做那些操作 . 关注高吞吐量,即Dgraph是否能够接受Flink引发的变异和查询负载?

    您可能遇到的主要问题是需要将数据转换为RDF格式以进行突变,并且查询需要采用我们使用的类似GraphQL的格式 .

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

    此外,很高兴了解您的具体用例,并在此提供更详细的答案:https://discuss.dgraph.io

相关问题