Gremlin，按边属性分组

如何解决Gremlin，按边属性分组

我正在使用 CosmosDB Gremlin 引擎并尝试编写一个查询，该查询返回所有 EDGE 属性，按键分组，并带有不同值的列表。

这是我的架构示例；

g.V().has('server','id','AARCWIVPAP13056').fold().coalesce(unfold(),addV('server').property('id','AARCWIVPAP13056').property('record_type','server').property('OsName','Microsoft Windows Server 2012 R2 Standard').property('CsCaption','AARCWIVPAP13056').property('OsType','WINNT').property('OsOperatingSystemSKU','StandardServerEdition').property('OsInstallDate','/Date(1478080755000)/').property('PSComputerName','None').property('WindowsEditionId','ServerStandard').property('WindowsProductName','Windows Server 2012 R2 Standard').property('BiosCaption','PhoenixBIOS 4.0 Release 6.0 ').property('CsNumberOfLogicalProcessors','1').property('CsNumberOfProcessors','1').property('CsTotalPhysicalMemory','8589463552').property('TotalPhysicalMemory','8'))

g.V().has('service','AdobeARMservice').fold().coalesce(unfold(),addV('service').property('id','AdobeARMservice').property('display_name','Adobe Acrobat Update Service').property('record_type','service').property('service_name','AdobeARMservice').property('name','AdobeARMservice'))
g.V('AARCWIVPAP13056').as('parent').V('AdobeARMservice').coalesce(__.inE('has_service').where(outV().as('parent')),addE('has_service').from('parent')).property('status','Stopped').property('service_account','LocalSystem').property('start_type','disabled')
g.V('AdobeARMservice').as('parent').V('AARCWIVPAP13056').coalesce(__.inE('installed_on').where(outV().as('parent')),addE('installed_on').from('parent')).property('status','disabled')

g.V().has('service','AdtAgent').fold().coalesce(unfold(),'AdtAgent').property('display_name','Microsoft Monitoring Agent Audit Forwarding').property('record_type','AdtAgent').property('name','AdtAgent'))
g.V('AARCWIVPAP13056').as('parent').V('AdtAgent').coalesce(__.inE('has_service').where(outV().as('parent')),'NT AUTHORITY\\NetworkService').property('start_type','disabled')
g.V('AdtAgent').as('parent').V('AARCWIVPAP13056').coalesce(__.inE('installed_on').where(outV().as('parent')),'AeLookupSvc').fold().coalesce(unfold(),'AeLookupSvc').property('display_name','Application Experience').property('record_type','AeLookupSvc').property('name','AeLookupSvc'))
g.V('AARCWIVPAP13056').as('parent').V('AeLookupSvc').coalesce(__.inE('has_service').where(outV().as('parent')),'localSystem').property('start_type','Manual')
g.V('AeLookupSvc').as('parent').V('AARCWIVPAP13056').coalesce(__.inE('installed_on').where(outV().as('parent')),'Manual')

g.V().has('service','ALG').fold().coalesce(unfold(),'ALG').property('display_name','Application Layer Gateway Service').property('record_type','ALG').property('name','ALG'))
g.V('AARCWIVPAP13056').as('parent').V('ALG').coalesce(__.inE('has_service').where(outV().as('parent')),'NT AUTHORITY\\LocalService').property('start_type','Manual')
g.V('ALG').as('parent').V('AARCWIVPAP13056').coalesce(__.inE('installed_on').where(outV().as('parent')),'Manual')



g.V().has('scheduled_task','computer_maintenance_-_sg_afi_compmaint_sa_0030_unv').fold().coalesce(unfold(),addV('scheduled_task').property('task_name','Computer Maintenance - SG_AFI_CompMaint_Sa_0030_Unv').property('id','computer_maintenance_-_sg_afi_compmaint_sa_0030_unv').property('record_type','scheduled_task').property('task_date','None').property('author','ASHLEYFURNITURE\\s_afiarcOMAct').property('task_path','\\'))
g.V('AARCWIVPAP13056').as('parent').V('computer_maintenance_-_sg_afi_compmaint_sa_0030_unv').coalesce(__.inE('runs_task').where(outV().as('parent')),addE('runs_task').from('parent'))
g.V('computer_maintenance_-_sg_afi_compmaint_sa_0030_unv').as('parent').V('AARCWIVPAP13056').coalesce(__.inE('task_runs_on').where(outV().as('parent')),addE('task_runs_on').from('parent'))

g.V().has('scheduled_task','configmgr_client_health').fold().coalesce(unfold(),'ConfigMgr Client Health').property('id','configmgr_client_health').property('record_type','\\'))
g.V('AARCWIVPAP13056').as('parent').V('configmgr_client_health').coalesce(__.inE('runs_task').where(outV().as('parent')),addE('runs_task').from('parent'))
g.V('configmgr_client_health').as('parent').V('AARCWIVPAP13056').coalesce(__.inE('task_runs_on').where(outV().as('parent')),addE('task_runs_on').from('parent'))

边上的属性根据我链接的 2 个顶点而变化，因此我无法在查询中指定属性名称。此外，一些 Edges 没有额外的属性。

以下查询使我接近我想要的输出；

g.V().has('id','AARCWIVPAP13056')
.as('entity')
.map(outE().group().by(label))
.as('edge')
.select('entity','edge')

但它返回所有原始边缘。

我的回复的理想形式是；

[
  {
    "entity": {
      "id": "AARCWIVPAP13056","label": "server","type": "vertex","properties": {
        "record_type": [
          {
            "id": "AARCWIVPAP13056|record_type","value": "server"
          }
        ],"OsName": [
          {
            "id": "55c70a2a-afb3-4aec-a4e1-86bcbd360068","value": "Microsoft Windows Server 2012 R2 Standard"
          }
        ],"CsCaption": [
          {
            "id": "819461e1-8833-4c65-858f-eeea1051edf9","value": "AARCWIVPAP13056"
          }
        ],"OsType": [
          {
            "id": "f1928eee-fdd1-479b-8b8d-361666761481","value": "WINNT"
          }
        ],"OsOperatingSystemSKU": [
          {
            "id": "bda0ceb5-d818-477d-8998-24537757225f","value": "StandardServerEdition"
          }
        ],"OsInstallDate": [
          {
            "id": "487beea1-4d7c-4e68-be0f-a3171c1f86db","value": "/Date(1478080755000)/"
          }
        ],"PSComputerName": [
          {
            "id": "2d3a9c6b-83c2-4058-a232-070d9928ed28","value": "None"
          }
        ],"WindowsEditionId": [
          {
            "id": "b0a0378c-901f-4510-a157-7fbc363d0c27","value": "ServerStandard"
          }
        ],"WindowsProductName": [
          {
            "id": "684f384c-2e19-427a-9c34-e7ee0a1c3c53","value": "Windows Server 2012 R2 Standard"
          }
        ],"BiosCaption": [
          {
            "id": "a8ea593b-6cee-42b6-9275-5d06ca4dd6a2","value": "PhoenixBIOS 4.0 Release 6.0     "
          }
        ],"CsNumberOfLogicalProcessors": [
          {
            "id": "a245cc43-d2d5-44e1-9696-f7fc585c6490","value": "1"
          }
        ],"CsNumberOfProcessors": [
          {
            "id": "67de0a1f-0bab-4dae-90d0-70c46dc50775","CsTotalPhysicalMemory": [
          {
            "id": "32def833-079b-4184-a428-46a400af9cb1","value": "8589463552"
          }
        ],"TotalPhysicalMemory": [
          {
            "id": "e6bfedb5-f8f5-460a-958e-1b287a407295","value": "8"
          }
        ],"role": [
          {
            "id": "d2943f08-d3a8-4ccd-94e8-188fc66f90aa","value": "APP"
          }
        ],"AppContact": [
          {
            "id": "a4c72bcc-f2c2-47c6-982f-f1819d7aa0ab","value": "Keith Branes"
          }
        ],"test": [
          {
            "id": "fd37a6de-e60c-4589-901f-1473cfd416a9","value": "tester"
          }
        ],"acl_test": [
          {
            "id": "aeb4d52b-5615-484f-917a-2a21f1a83260","value": "acl_test_value","properties": {
              "harvested": "private"
            }
          }
        ],"acl_test2": [
          {
            "id": "0b3b5216-3a1d-4817-bcb2-8acd2c9bcffa","value": "acl_test_value2","properties": {
              "read_only": "true"
            }
          }
        ],"tester": [
          {
            "id": "c0a1f3b0-4a26-40b2-a762-8a1e008dbcb0","value": "rester"
          }
        ]
      }
    },"edge": {
      "has_service": [
        {
            "status": ["Running","Stopped"],"start_type": ["Manual","disabled"],"service_account": [ "Network Service","LocalSystem" ]
          }],"runs_task": []
    }
]

解决方法

您的数据和查询仍然没有返回任何数据，而且它有点复杂，所以我不确定它在哪里断开连接以修复它。无论如何，从你写的内容来看，我认为你可以用 project() 做你想做的事：

gremlin> g.V().has('person','name','marko').
......1>   project('entity','edgeData').
......2>     by(valueMap(true)).
......3>     by(outE().properties().group().by(key()).by(value().fold()))
==>[entity:[id:1,label:person,name:[marko],age:[29]],edgeData:[weight:[0.4,0.5,1.0]]]