循环多个 JSON 数组以根据 Ansible 中的键值过滤相关的 JSON 对象

Question

我正在尝试遍历 2 个不同的 JSON 数组并仅在 2 个键值相同时进行过滤。

我正在比较来自 po-orig.json/po 文件的 cidr 和来自 pocooling json 的 subnet。如果两个文件中的键值相同，则将 pocooling json 文件的相关详细信息打印为列表。

- name: Combine GP MGMT
      vars:
       pocidr: >-
         {{
          po 
          | json_query('ansible_facts.policyobject[].json[]')
         }}
       poname: >-
         {{
         pocidr
          | selectattr('cidr', '==', item.subnet)
          | map(attribute='name')
          | list
         }}
      set_fact:
       result: >-
         {{ 
            result | default([])
            +
            [poname]
         }}
      with_items: "{{ pocooling }}"

更新代码

 - name: Compare the Current & Actual GP policy
      set_fact: 
           pocidr: "{{ po | json_query(\"ansible_facts.policyobject[].json[]\") }}"

    - name: Combine GP MGMT
      vars:
       poname: 
         "{{
         pocidr
          | selectattr('cidr', '==', item.subnet)
          | map(attribute='name')
          | first
         }}"
      set_fact:
       result: 
         "{{ 
            result | default([])
            +
            [poname]
         }}"
      with_items: "{{ pocooling }}"

pocooling.json

[
    {
        "applianceIp": "10.10.10.10",
        "dhcpBootOptionsEnabled": false,
        "dhcpHandling": "Run a DHCP server",
        "dhcpLeaseTime": "1 day",
        "dhcpOptions": [],
        "dnsNameservers": "upstream_dns",
        "fixedIpAssignments": {},
        "id": 2222,
        "name": "Cooling",
        "networkId": "78984654989",
        "reservedIpRanges": [],
        "subnet": "10.10.10.0/28"
    },
    {
        "applianceIp": "10.10.10.10",
        "dhcpBootOptionsEnabled": false,
        "dhcpHandling": "Run a DHCP server",
        "dhcpLeaseTime": "1 day",
        "dhcpOptions": [],
        "dnsNameservers": "upstream_dns",
        "fixedIpAssignments": {},
        "id": 2222,
        "name": "Cooling",
        "networkId": "123456789",
        "reservedIpRanges": [],
        "subnet": "10.11.11.0/28"
    }
]

po-orig.json(po)

{
   "ansible_facts":{
      "policyobject":[
         {
            "invocation":{
               "module_args":{
                  "status_code":[
                     200,
                     201,
                     202
                  ],
                  "validate_certs":false
               }
            },
            "item":{
               "id":"123456",
               "name":"DC"
            },
            "json":[
               {
                  "category":"network",
                  "cidr":"10.1.1.1/28",
                  "createdAt":"2021-11-23T19:48:21Z",
                  "groupIds":[
                     
                  ],
                  "id":"545649843651365",
                  "name":"JM-Privat",
                  "networkIds":[
                     "545649843651365"
                  ],
                  "type":"cidr",
                  "updatedAt":"2021-11-23T19:48:21Z"
               },
               {
                  "category":"network",
                  "cidr":"10.10.10.0/28",
                  "createdAt":"2021-12-07T13:54:05Z",
                  "groupIds":[
                     "897987654689854"
                  ],
                  "id":"564678984565465",
                  "name":"PO-L-DE-MCC-COOLING_DMZ_LAB",
                  "networkIds":[
                     
                  ],
                  "type":"cidr",
                  "updatedAt":"2021-12-07T13:54:05Z"
               }
            ]
         }
      ]
   }
}

错误：

fatal: [localhost]: FAILED! => {"msg": "The task includes an option with an undefined variable. The error was: {{ pocidr\n | selectattr('cidr', '==', item.subnet)\n | map(attribute='name')\n | list\n}}: 'dict object' has no attribute 'cidr

预期结果

[
    {
        "applianceIp": "10.10.10.10",
        "dhcpBootOptionsEnabled": false,
        "dhcpHandling": "Run a DHCP server",
        "dhcpLeaseTime": "1 day",
        "dhcpOptions": [],
        "dnsNameservers": "upstream_dns",
        "fixedIpAssignments": {},
        "id": 2222,
        "name": "Cooling",
        "networkId": "78984654989",
        "reservedIpRanges": [],
        "subnet": "10.10.10.0/28"
    }
]

完成剧本

- name:  Test 
  hosts: localhost
  connection: local
  gather_facts: false
  vars:
    pocooling: "{{ lookup('file', 'pocooling.json') | from_json }}"

  tasks:
    - include_vars:
        file: po-orig.json
        name: po
    - name: Combine GP MGMT
      vars:
        poname: "{{ po|json_query('ansible_facts.policyobject[].json[]')|
                    selectattr('cidr', '==', item.subnet)|
                    map(attribute='name')|
                    list }}"
      set_fact:
        result: "{{ result|default([]) + [poname] }}"
      loop: "{{ pocooling }}"

Answer 1

给定列表

  pocooling:
  - networkId: '78984654989'
    subnet: 10.10.10.0/28
  - networkId: '123456789'
    subnet: 10.11.11.0/28

Select cidr

列表

  _cidr: "{{ ansible_facts.policyobject|json_query('[].json[].cidr') }}"

给予

  _cidr:
  - 10.1.1.1/28
  - 10.10.10.0/28

然后select符合条件的项目

    - debug:
        msg: "{{ pocooling|selectattr('subnet', 'in' , _cidr) }}"
      vars:
        _cidr: "{{ ansible_facts.policyobject|json_query('[].json[].cidr') }}"

给予

  msg:
  - networkId: '78984654989'
    subnet: 10.10.10.0/28

^{您的代码，经过修复和简化
- include_vars:
file: po-orig.json
name: po
- name: Combine GP MGMT
vars:
poname: "{{ po|json_query('ansible_facts.policyobject[].json[]')|
selectattr('cidr', '==', item.subnet)|
map(attribute='name')|
list }}"
set_fact:
result: "{{ result|default([]) + [poname] }}"
loop: "{{ pocooling }}"

给予
result:
- - PO-L-DE-MCC-COOLING_DMZ_LAB
- []}

循环多个 JSON 数组以根据 Ansible 中的键值过滤相关的 JSON 对象

Loop over multiple JSON arrays to filter the relevant JSON object based on a key value in Ansible

json

jinja2

ansible