Gremlin: получить ключи свойств Vertex, сгруппированные по родительской вершине - PullRequest
1 голос
/ 23 февраля 2020

пример данных:

    g.addV('organisation').property('id', 1).property('name', 'org-1').as('org1').
addV('cloud-service-provider').property('id', 1).property('name', 'AWS').as('aws').
addV('cloud-service-provider').property('id', 2).property('name', 'Azure').as('azure').
addV('account').property('id', 1).property('name', 'aws-account-11').as('aws-account').
addV('account').property('id', 2).property('name', 'azure-account-22').as('azure-account').
addV('region').property('id', 1).property('name', 'us-east-1').as('aws-region-us-east-1').
addV('region').property('id', 1).property('name', 'us-west-2').as('azure-region-us-west-2').
addV('region').property('id', 2).property('name', 'us-west-2').as('aws-region-us-west-2').
addV('sql-server').property('id', 1).property('name', 'my-sql-server').property('version', 'v1').as('sql-server').
addV('security-group').property('id', 1).property('name', 'sg-1').as('sg-1').
addV('inbound-rule').property('id', 1).property('fromPort', 1).property('toPort', 65636).as('inbound-rule-1').
addV('inbound-rule').property('id', 2).property('fromPort', 5).property('toPort', 8001).as('inbound-rule-2').
addV('outbound-rule').property('id', 1).property('fromPort', 100).property('toPort', 200).as('outbound-rule-1').
addV('user-id-group-pair').property('id', 1).property('groupId', 'group-1').property('groupName', 'my-group').property('user-id', 'u-1').as('user-id-group-pair').
addE('uses').from('org1').to('aws').
addE('uses').from('org1').to('azure').
addE('has').from('aws').to('aws-account').
addE('has').from('azure').to('azure-account').
addE('has').from('aws-account').to('aws-region-us-east-1').
addE('has').from('aws-account').to('aws-region-us-west-2').
addE('has').from('azure-account').to('azure-region-us-west-2').
addE('has').from('azure-region-us-west-2').to('sql-server').
addE('has').from('aws-region-us-east-1').to('sg-1').
addE('has_property').from('sg-1').to('inbound-rule-1').
addE('has_property').from('sg-1').to('inbound-rule-2').
addE('has_property').from('sg-1').to('outbound-rule-1').
addE('has_property').from('inbound-rule-1').to('user-id-group-pair').
iterate();

Я хочу получить все ключи свойств , сгруппированные по вершина верхнего уровня 'cloud-service-provider'

g.V().group().by(T.label).by(__.properties().label().dedup().fold()).toList()

дает ключи свойств, но я хочу применить группировку и к родительской вершине

ps В образце графа есть специальная метка ребра - 'has_property'

Сложные свойства вершины, такие как Списки и карты (в java) моделируются с использованием этой метки ребра

Ожидаемый вывод :

Например,

Для Azure -> ожидаемый результат:

[account.id,
account.name,
region.id,
region.name,
sql-server.id,
sql-server.version]

для aws -> ожидаемый результат:

[account.id,
account.name,
region.id,
region.name,
security_group.id,
security_group.name,
security_group.inbound_rule.fromPort(inbound_rule is a property of security_group),
security_group.inbound_rule.toPort,
security_group.inbound_rule.id,
security_group.outbound_rule.fromPort,
security_group.outbound_rule.toPort,
security_group.outbound_rule.id,
security_group.inbound_rule.user-id-group-pair.groupId(user-id-group-pair is a property of inbound_rule),
security_group.inbound_rule.user-id-group-pair.groupName,
security_group.inbound_rule.user-id-group-pair.userId,
security_group.inbound_rule.user-id-group-pair.id]

1 Ответ

4 голосов
/ 25 февраля 2020

Удивительно, что вы можете сделать это с помощью gremlin:

g.V().out("uses").project("csp","props")
.by("name")
.by(
    repeat(out("has")).emit().as("a")
    .emit().repeat(out("has_property"))
    .properties().path().by(label).from("a")
    .select(values).dedup()
    .fold()
)

Выводом будет массив поставщиков услуг, каждый из которых имеет имя и список свойств. Каждое свойство является массивом, к которому вы должны присоединиться (.), Чтобы получить окончательный результат.

Вы можете попробовать здесь .

...