如何使用 gremlin 查询根据用户权限进行过滤？

Question

我对图形数据库相当陌生，但是我已经广泛使用 SQL Server 和文档数据库（Lucene、DocumentDb 等）。我完全有可能以错误的方式处理此查询，因为我是图形数据库的新手。我正在尝试将一些逻辑转换为我们目前正在使用 SQL Server 的图形数据库（具体来说是通过 Gremlins 的 CosmosDB Graph）。更改的原因是这个问题集并不是 SQL Server 真正擅长的，因此我们的 SQL 查询（我们已经尽我们所能优化）真正开始成为我们应用程序的热点。

为了非常简要地概述我们的逻辑，我们运营了一个网上商店，允许管理员配置产品和用户具有多个级别的细粒度权限（如下所述）。根据这些权限，我们只向用户显示他们被允许查看的产品。

实体：

• 地区：一个地区由多个国家/地区组成
• 国家：一个国家有很多市场和很多地区
• 市场：市场是一个国家/地区的一组商店
• 商店：商店属于单一市场

用户拥有以下一组权限，每组可以包含多个值：

• 可以查看区域
• 可以查看国家
• 可以查看市场
• 可以查看商店

产品具有以下一组权限，每组可以包含多个值：

• 对区域可见
• 对国家可见
• 市场可见
• 对商店可见

尝试了几天后，这是我想出的查询。此查询确实有效并为给定用户返回了正确的产品，但是执行大约需要 25 秒。

g.V().has('user','username', 'john.doe').union(
    __.out('can-view-region').out('contains-country').in('in-market').hasLabel('store'),
    __.out('can-view-country').in('in-market').hasLabel('store'),
    __.out('can-view-market').in('in-market').hasLabel('store'),
    __.out('can-view-store')
).dedup().union(
    __.out('in-market').in('contains-country').in('visible-to-region').hasLabel('product'),
    __.out('in-market').in('visible-to-country').hasLabel('product'),
    __.out('in-market').in('visible-to-market').hasLabel('product'),
    __.in('visible-to-store').hasLabel('product')
).dedup()

有没有更好的方法来做到这一点？这个问题可能不是最适合图形数据库吗？

任何帮助将不胜感激！

谢谢， 克里斯

Answer 1

我认为这不会有太大帮助，但这是您查询的改进版本：

g.V().has('user','username', 'john.doe').union(
    __.out('can-view-region').out('contains-country').in('in-market').hasLabel('store'),
    __.out('can-view-country','can-view-market').in('in-market').hasLabel('store'),
    __.out('can-view-store')
).dedup().union(
    __.out('in-market').union(
      __.in('contains-country').in('visible-to-region'),
      __.in('visible-to-country','visible-to-market')).hasLabel('product'),
    __.in('visible-to-store').hasLabel('product')
).dedup()

我想知道hasLabel() 检查是否真的有必要。例如，如果.in('in-market') 只能引导一个store 顶点，则删除额外的检查。

此外，创建捷径边缘可能是值得的。每当您更改权限时，这都会增加写入时间，但会显着增加给定查询的读取时间。由于读取可能比权限更新更频繁地发生，这可能是一个很好的权衡。

Answer 2

CosmosDB Graph 团队正在研究可以在 union 步骤上进行的改进。

尚未建议的其他选项：

1. 使用附加谓词减少每跳遍历的边数。例如： g.V('1').outE('market').has('prop', 'value').inV()

2. 是否可以在您的客户端代码中拆分遍历并执行并行请求？由于您使用的是 .NET，因此您可以在第一个联合中获取每个结果，并为第二个联合中的遍历执行并行请求。像这样的东西（未经测试的代码）：

   string firstUnion = @"g.V().has('user','username', 'john.doe').union(
       __.out('can-view-region').out('contains-country').in('in-market').hasLabel('store'),
       __.out('can-view-country').in('in-market').hasLabel('store'),
       __.out('can-view-market').in('in-market').hasLabel('store'),
       __.out('can-view-store')
   ).dedup()"
   
   string[] secondUnionTraversals = new[] {
       "g.V({0}).out('in-market').in('contains-country').in('visible-to-region').hasLabel('product')",
       "g.V({0}).out('in-market').in('visible-to-country').hasLabel('product')",
       "g.V({0}).out('in-market').in('visible-to-market').hasLabel('product')",
       "g.V({0}).in('visible-to-store').hasLabel('product')",
   };
   
   var response = client.CreateGremlinQuery(col, firstUnion);
   while (response.HasMoreResults)
   {
       var results = await response.ExecuteNextAsync<Vertex>();
       foreach (Vertex v in results)
       {
           Parallel.ForEach(secondUnionTraversals, (traversal) =>
           {
               var secondResponse = client.CreateGremlinQuery<Vertex>(col, string.Format(traversal, v.Id));
               while (secondResponse.HasMoreResults)
               {
                   concurrentColl.Add(secondResponse);
               }
           });
       }
   }