Ansible - 如何将 selectattr 与不同键的 yaml 一起使用

Question

我正在努力做一件简单的事情（我认为这应该很容易），通过解析 yaml 并过滤 Ansible 中的某些键。

我的 yaml 文件如下所示：

---

- vm: "vm1"
  ip: 10.10.10.1
- vm: "vm2"
  ip: 10.10.10.2
- test_vm: something
- another_vm: something_other

所以我认为不是像

这样的表达

lookup('file','my_file.yaml') | from_yaml | selectattr('vm','search','vm1')|list

可以，但会出现类似

的错误

fatal: [localhost]: FAILED! => {"msg": "Unexpected templating type error occurred on ({{ lookup('file','{{sysfile}}') | from_yaml | selectattr('vm','search','vm1')|list}}): expected string or bytes-like object"}

如果我删除 test_vm 和 another_vm 键，它工作正常。

ok: [localhost] => {
    "msg": [
        {
            "ip": "10.10.10.1",
            "vm": "vm1"
        }
    ]
}

如果我尝试搜索 test_vm 键，它会失败：

fatal: [localhost]: FAILED! => {"msg": "The task includes an option with an undefined variable. The error was: 'dict object' has no attribute 'test_vm'\n\nThe error appears to be ...

selectattr 过滤器是否期望列表中的所有 dicts 具有相同的键？因为不能使用 Jinja2 过滤自定义 dicts 列表没有任何意义。

例如，如果我有一个更复杂的 yaml（不是那么平坦），我是否仅限于在 Ansible 中搜索和过滤？

例如，如果我有一个 yaml，如下所示：

---

- vm: "vm1"
  ip: 10.10.10.1
- vm: "vm2"
  ip: 10.10.10.2
- test_vm: something
   - process_1: X
   - process_2: Y
   - process_3: Z
- another_vm: something_other

例如，我如何快速过滤 process_2？ 有什么办法吗？

非常感谢。

Answer 1

更准确地说，它期望列表中的所有 dicts 都具有您选择的属性。

并非所有过滤器功能都 100% 正确，通过并非由所有元素定义的属性来选择对象：

{{ test_var | selectattr('vm','defined') |selectattr('vm','equalto','vm1') | list }} 

Answer 2

selectattr 过滤器是否期望列表中的所有 dicts 具有相同的键？

更准确地说，它期望列表中的所有 dicts 都具有您选择的属性。如果不是列表中的所有 dict 都有它，您必须首先过滤掉未定义的项目。这也可以通过selectattr 完成。 （感谢@Randy 在我最初的回答之后让这一点更清楚）。

在您的情况下，json_query filter（实现jmespath）有时也可以以更紧凑的方式完成这项工作。但它不是核心过滤器，需要安装community.general collection。

以下是从您的上述要求中提取的一些示例，这些示例同时使用核心过滤器和json_query 解决方案解决。

剧本：

---
- name: "Filter data with core filters or json query"
  hosts: "localhost"
  gather_facts: false

  vars:
    # Your initial data on a single line for legibility
    test_var: [{"vm":"vm1"},{"ip":"10.10.10.1"},{"vm":"vm2","ip":"10.10.10.2"},{"test_vm":"something","process_1":"X","process_2":"Y","process_3":"Z"},{"another_vm":"something_other"}]

  tasks:
    - name: Get objects having vm==vm1
      vars:
        msg: |-
          With core filters: {{ test_var | selectattr('vm', 'defined') | selectattr('vm', '==', 'vm1') | list }}
          With json_query: {{ test_var | json_query("[?vm=='vm1']") | list }}
      debug:
        msg: "{{ msg.split('\n') }}"

    - name: Get all objects having vm attribute
      vars:
        msg: |-
          With core filters: {{ test_var | selectattr('vm', 'defined') | list }}
          With json_query: {{ test_var | json_query("[?vm]") | list }}
      debug:
        msg: "{{ msg.split('\n') }}"

    - name: Get all objects having process_2 attribute
      vars:
        msg: |-
          With core filters: {{ test_var | selectattr('process_2', 'defined') | list }}
          With json_query: {{ test_var | json_query("[?process_2]") | list }}
      debug:
        msg: "{{ msg.split('\n') }}"

    - name: Get only a list of process_2 attributes
      vars:
        msg: |-
          With core filters: {{ test_var | selectattr('process_2', 'defined') | map(attribute='process_2') | list }}
          With json_query: {{ test_var | json_query("[].process_2") | list }}
      debug:
        msg: "{{ msg.split('\n') }}"

给出：

PLAY [Filter data with core filters or json query] *********************************************************************

TASK [Get objects having vm==vm1] *********************************************************************
ok: [localhost] => {
    "msg": [
        "With core filters: [{'vm': 'vm1', 'ip': '10.10.10.1'}]",
        "With json_query: [{'vm': 'vm1', 'ip': '10.10.10.1'}]"
    ]
}

TASK [Get all objects having vm attribute] *********************************************************************
ok: [localhost] => {
    "msg": [
        "With core filters: [{'vm': 'vm1', 'ip': '10.10.10.1'}, {'vm': 'vm2', 'ip': '10.10.10.2'}]",
        "With json_query: [{'vm': 'vm1', 'ip': '10.10.10.1'}, {'vm': 'vm2', 'ip': '10.10.10.2'}]"
    ]
}

TASK [Get all objects having process_2 attribute] *********************************************************************
ok: [localhost] => {
    "msg": [
        "With core filters: [{'test_vm': 'something', 'process_1': 'X', 'process_2': 'Y', 'process_3': 'Z'}]",
        "With json_query: [{'test_vm': 'something', 'process_1': 'X', 'process_2': 'Y', 'process_3': 'Z'}]"
    ]
}

TASK [Get only a list of process_2 attributes] *********************************************************************
ok: [localhost] => {
    "msg": [
        "With core filters: ['Y']",
        "With json_query: ['Y']"
    ]
}

PLAY RECAP *********************************************************************
localhost                  : ok=4    changed=0    unreachable=0    failed=0    skipped=0    rescued=0    ignored=0