Gremlin中如何实现BFS遍历下每个节点的出边条数独立限制

背景 #

参考下图，我们当前在实现广度级别的限制逻辑时遇到了问题。
我们的目标是确保对每个邻居节点，从当前节点读取的边数不超过X，避免边数过多的节点导致遍历超时。

示例说明 #

我们设置最大广度限制为X，即单个节点最多聚合的邻居数。从节点0启动BFS遍历，聚合到3、1、2三个节点。
假设最大广度限制为3，可能出现的问题是：我们先拉取到节点1后立即读取其所有邻居，最终节点1的邻居就占满了3条的限制，导致完全忽略了节点3和2的邻居。

问题咨询 #

请问如何在单个Gremlin查询中实现：对遍历到的所有邻居节点，每个节点的出边条数都做独立限制？
即我需要从节点3获取X个邻居、节点1获取X个邻居、节点2获取X个邻居，且该规则需要递归生效直到达到指定遍历深度D。

现有尝试及问题 #

当前尝试的语句：g.V(idsList).outE().limit(50).inV().dedup.by(T.id).fold()
上述写法的问题是：会对所有邻居节点的出边整体限制为X条，可能会仅返回单个子图的内容，无法覆盖所有节点的邻居。

解决方案 #

要实现每个节点独立限制出边数量，同时支持指定深度的递归遍历，核心是用local()步骤将limit作用在单个节点的出边流上，而非全局流，再搭配repeat()实现深度控制，示例代码如下：

// 替换X为单节点最大出边数，D为最大遍历深度
g.V(idsList)
  .repeat(
    // 每个节点单独执行出边查询，各自限制最多X条
    local(outE().limit(X).inV())
    .dedup().by(T.id) // 同层去重，避免重复节点重复遍历
    .simplePath() // 可选：禁止循环路径，防止死循环
  )
  .times(D) // 控制遍历深度为D
  .dedup().by(T.id) // 全局去重所有遍历到的节点
  .fold()

关键逻辑说明 #

• local()是核心：原有写法的limit作用在所有节点出边组成的全局流上，只要单个节点的出边数达到限制值，其他节点的出边就不会被处理。local()会将内部的遍历逻辑单独作用在每个输入节点上，每个节点各自执行出边查询、各自限制X条，完全避免单节点占满配额的问题。
• 如果不需要保留边的相关信息，可以将local(outE().limit(X).inV())简化为local(out().limit(X))，查询性能更好。
• 如果需要保留完整的遍历树结构而非拍平的节点列表，可以在末尾替换fold()为tree()，可以清晰看到每个节点对应的下级邻居。

内容的提问来源于stack exchange，提问作者Ryan