基于事实的Ansible循环以重新启动Kafka连接器失败任务

Question

在这里，我想重新启动KAFKA连接任务，如果使用Ansible-PlayBook处于失败状态，我已经使用'set_fact'来获取连接器任务状态 我想对收集的事实创建一个循环，以使用连接器名称和任务ID重新启动KAFKA连接器任务。

  tasks:
    - name: Gethering Connector Names
      uri:
        url: "{{scheme }}://{{ server }}:{{ port_no }}/connectors"
        user: "{{ username }}"
        password: "{{ password }}"
        method: GET
        force_basic_auth: yes
        status_code: 200
      register: conn_stat
    - name: Checking for Connector status
      uri:
        url: "{{scheme }}://{{ server }}:{{ port_no }}/connectors/{{ abc_conn_name }}/status"
        user: "{{ username }}"
        password: "{{ password }}"
        method: GET
        force_basic_auth: yes
      loop: "{{ conn_name }}"
      loop_control:
        loop_var: abc_conn_name
      vars:
        conn_name: "{{ conn_stat.json }}"
      register: conn_stat_1
    - name: Gethering Failed task id
      set_fact:
        failed_connector_name_task_id: "{{ conn_stat_1 | json_query('results[].json[].{name: name ,id: [tasks[?state == `RUNNING`].id [] | [0] ]}')  }}"
    - name: Failed connector name with tasks id
      ansible.builtin.debug:
        var:  failed_connector_name_task_id

从事实中获得低于值，我需要将其推向循环

        "failed_connector_name_task_id": [
            {
                "id": [
                    0
                    1
                ],
                "name": "test-connector-sample"
            },
            {
                "id": [
                    0
                    1
                ],
                "name": "confluent-connect"
            },
            {
                "id": [
                    0
                    1
                    2
                ],
                "name": "confluent-test-1"
            }
        ]
    },
    "changed": false
}

值，需要发布

    - name: Restart Connector Failed tasks 
      uri:
        url: "{{scheme }}://{{ server }}:{{ port_no }}/connectors/**{{name of connector}}**/tasks/**{{task ID}}**/restart"
        user: "{{ username }}"
        password: "{{ password }}"
        method: POST
        force_basic_auth: yes
        status_code: 200
      register: conn_stat

连接器的名称， 任务ID 想要在循环中使用。

在上面，我需要设置任务循环。 正如我们可以看到的那样，连接器“ Confluent-Test-1”具有三个在失败状态下的任务，因此必须使用任务“ Confluent-Test-1”进行三次迭代。

Answer 1

这是您要通过上述 filter 或。 过滤器引用的示例

    - name: Restart Connector Failed tasks 
      uri:
        url: "{{scheme }}://{{ server }}:{{ port_no }}/connectors/{{ item.0.name }}/tasks/{{ item.1 }}/restart"
        user: "{{ username }}"
        password: "{{ password }}"
        method: POST
        force_basic_auth: yes
        status_code: 200
      loop: "{{ failed_connector_name_task_id | subelements('id', skip_missing=True) }}"

这是使用值得阅读的

• ：

---

”您的最后一个不必要的set_fact带有以下构造的任务：

    - name: Restart Connector Failed tasks
      vars:
        failed_connector_name_task_id: "{{ conn_stat_1 | json_query('results[].json[].{name: name ,id: [tasks[?state == `RUNNING`].id [] | [0] ]}') }}"
      uri:
        url: "{{scheme }}://{{ server }}:{{ port_no }}/connectors/{{ item.0.name }}/tasks/{{ item.1 }}/restart"
        user: "{{ username }}"
        password: "{{ password }}"
        method: POST
        force_basic_auth: yes
        status_code: 200
      loop: "{{ failed_connector_name_task_id | subelements('id', skip_missing=True) }}"