Получить все ребра между несколькими вершинами - JanusGraph - PullRequest
Новая
       8

Получить все ребра между несколькими вершинами - JanusGraph

0 голосов
/ 30 апреля 2019

Я пытаюсь написать гремлиновый запрос, чтобы получить все ребра между списком вершин.

Данные отредактированы для защиты конфиденциальности.Пользователь A (42651832) -reports_to-> Пользователь B (28729440) -reports_to-> Пользователь C (19546208)

ids = [19546208, 28729440, 42651832]

Мне нужнонайти все ребра между произвольным списком вершин

Кажется простым, но я не могу написать запрос, который дает нужные мне результаты. 

gremlin> g.V(42651832).outE('reports_to').otherV().id()
==>28729440
gremlin> g.V(28729440).outE('reports_to').otherV().id()
==>19546208
gremlin> ids = [19546208, 28729440, 42651832]
==>19546208
==>28729440
==>42651832
gremlin> g.V(ids)
==>v[19546208]
==>v[28729440]
==>v[42651832]
gremlin> g.V(ids).bothE().where(otherV().hasId(ids))
gremlin> g.V(ids).bothE().where(otherV().hasId(within(ids)))
gremlin> g.V(ids).bothE().where(otherV().hasId(within(19546208, 28729440, 42651832)))

Очевидно, я думаю, что есть типпроблема преобразования между консолью gremlin и JanusGraph.

цитирование в виде строки или преобразование в Long, похоже, работает. 

gremlin> g.V(ids).bothE().where(otherV().hasId(within("19546208", "28729440", "42651832")))
==>e[10r7d8-h3rs0-i6t-bmxy8][28729440-reports_to->19546208]
==>e[10r7d8-h3rs0-i6t-bmxy8][28729440-reports_to->19546208]
==>e[128qvr-pe6d4-i6t-h3rs0][42651832-reports_to->28729440]
==>e[128qvr-pe6d4-i6t-h3rs0][42651832-reports_to->28729440]
gremlin> g.V(ids).bothE().where(otherV().hasId(within(19546208L, 28729440L, 42651832L)))
==>e[10r7d8-h3rs0-i6t-bmxy8][28729440-reports_to->19546208]
==>e[10r7d8-h3rs0-i6t-bmxy8][28729440-reports_to->19546208]
==>e[128qvr-pe6d4-i6t-h3rs0][42651832-reports_to->28729440]
==>e[128qvr-pe6d4-i6t-h3rs0][42651832-reports_to->28729440]
gremlin>  

gremlin> g.V(ids).bothE().where(otherV().hasId(within(19546208L, 28729440L, 42651832L))).dedup()
==>e[10r7d8-h3rs0-i6t-bmxy8][28729440-reports_to->19546208]
==>e[128qvr-pe6d4-i6t-h3rs0][42651832-reports_to->28729440]

Любые другие предложения.Не уверен, почему JanusGraph работает именно так.

1 Ответ

1 голос
/ 01 мая 2019

Это не совсем полный ответ, но, надеюсь, он подберет вас достаточно близко.Я использовал GraphOfTheGods для проверки.

Это позволит получить все пути из списка идентификаторов к идентификаторам в кавычках в hasID (), а затем вывести список всех ребер, пройденных в каждом пути.Я добавил ограничение на удобочитаемость.Вы можете легко добавить все значения в набор, чтобы получить дедуплицированный ответ. 

# Save all the graph of the gods vertex ids to a variable
ids = [4112,4128,4136,8232,12328,16424,20520,4296,4328,4344,8440,12536]
paths = g.V(ids).until(hasId("8440","12536")).repeat(bothE().aggregate("e").otherV().simplePath()).limit(3).select('e')
==>[e[74v-6ig-9hx-368][8440-battled->4112]]
==>[e[74v-6ig-9hx-368][8440-battled->4112],e[7xb-6ig-9hx-36o][8440-battled->4128],e[1l0-36o-b2t-9o8][4128-lives->12536],e[9vp-co8-bv9-36o][16424-pet->4128]]
==>[e[74v-6ig-9hx-368][8440-battled->4112],e[7xb-6ig-9hx-36o][8440-battled->4128],e[1l0-36o-b2t-9o8][4128-lives->12536],e[9vp-co8-bv9-36o][16424-pet->4128]]

Первоначально я смог получить полный путь с соединительными вершинами, который я включил на случай, если он потенциально может быть полезен. 

paths = g.V(ids).until(hasId("8440","12536")).repeat(bothE().otherV().simplePath()).path().limit(5)
==>[v[4112],e[74v-6ig-9hx-368][8440-battled->4112],v[8440]]
==>[v[4128],e[7xb-6ig-9hx-36o][8440-battled->4128],v[8440]]
==>[v[4128],e[1l0-36o-b2t-9o8][4128-lives->12536],v[12536]]
==>[v[4128],e[9vp-co8-bv9-36o][16424-pet->4128],v[16424],e[9hh-co8-b2t-9o8][16424-lives->12536],v[12536]]
==>[v[4128],e[9vp-co8-bv9-36o][16424-pet->4128],v[16424],e[8p1-co8-cnp-3co][16424-brother->4344],v[4344],e[6cf-6ig-7x1-3co][8440-father->4344],v[8440]]

Отдельно я провел некоторые проверки с помощью GraphOfTheGods и шага explain(), и это определенно выглядит как ошибка.Если я устанавливаю список в переменную, он выполняет равный шаг вместо шага в течение шага. 

paths = g.V(ids).until(hasId(ids)).repeat(out().simplePath()).limit(10).path().explain()
...RepeatStep(until([HasStep([~id.eq([4112, 4128, ...])])]),

, где, как перечисление в кавычках, он будет правильно выполнять проверку внутри. 

paths = g.V(ids).until(hasId("8440","12536")).repeat(outE().simplePath()).limit(10).path().explain()
...RepeatStep(until([HasStep([~id.within([8440, 12536])])])
...