Ansible async_status 任务 - 错误：ansible_job_id“未定义变量”

我有一个 3 节点 ubuntu 20.04 lts - kvm - kubernetes 集群，kvm-host 也是 ubuntu 20.04 lts。我在 kvm 主机上运行了 playbook。 我有以下库存摘录：

nodes:
  hosts:
    sea_r:
      ansible_host: 192.168.122.60
    spring_r:
      ansible_host: 192.168.122.92
    island_r:
      ansible_host: 192.168.122.93
  vars:
    ansible_user: root

and 已经尝试了很多async_status，但总是失败,

- name: root commands
  hosts: nodes
  tasks:
  - name: bash commands
    ansible.builtin.shell: |
      apt update
    args:
      chdir: /root
      executable: /bin/bash
    async: 2000
    poll: 2
    register: output

  - name: check progress
    ansible.builtin.async_status:
      jid: "{{ output.ansible_job_id }}"
    register: job_result
    until: job_result.finished
    retries: 200
    delay: 5

有错误：

fatal: [sea_r]: FAILED! => {"msg": "The task
includes an option with an undefined variable. 
The error was: 'dict object' has no attribute
'ansible_job_id' ...

如果我尝试以下操作，

- name: root commands
  hosts: nodes
  tasks:
  - name: bash commands
    ansible.builtin.shell: |
      apt update
    args:
      chdir: /root
      executable: /bin/bash
    async: 2000
    poll: 2
    register: output
  - debug: msg="{{ output.stdout_lines }}"
  - debug: msg="{{ output.stderr_lines }}"

我没有收到任何错误。 还尝试了以下变化，

  - name: check progress
    ansible.builtin.async_status:
      jid: "{{ item.ansible_job_id }}"
    with_items: "{{ output }}"
    register: job_result
    until: job_result.finished
    retries: 200
    delay: 5

这是建议的作为类似错误的解决方案。这也没有帮助，我只是得到稍微不同的错误：

fatal: [sea_r]: FAILED! => {"msg": "The task includes
an option with an undefined variable. The error 
was: 'ansible.utils.unsafe_proxy.AnsibleUnsafeText
object' has no attribute 'ansible_job_id' ...

在剧本的开头和结尾，我恢复和暂停 3 个 kvm 服务器节点，如下所示：

- name: resume vms
  hosts: local_vm_ctl
  tasks:
  - name: resume vm servers
    shell: |
      virsh resume kub3
      virsh resume kub2
      virsh resume kub1
      virsh list --state-paused --state-running
    args:
      chdir: /home/bi
      executable: /bin/bash
    environment:
      LIBVIRT_DEFAULT_URI: qemu:///system
    register: output
  - debug: msg="{{ output.stdout_lines }}"
  - debug: msg="{{ output.stderr_lines }}"

and so

- name: pause vms
  hosts: local_vm_ctl
  tasks:
  - name: suspend vm servers
    shell: |
      virsh suspend kub3
      virsh suspend kub2
      virsh suspend kub1
      virsh list --state-paused --state-running
    args:
      chdir: /home/bi
      executable: /bin/bash
    environment:
      LIBVIRT_DEFAULT_URI: qemu:///system
    register: output
  - debug: msg="{{ output.stdout_lines }}"
  - debug: msg="{{ output.stderr_lines }}"

但我不明白这些戏剧与上述错误有什么关系。

任何帮助都感激不尽。

您的作业 ID 出现未定义错误，因为：

1. You use poll: X在您的初始任务中，ansible 每 X 秒连接一次以检查任务是否完成
2. 当 ansible 存在该任务并进入您的下一个任务时async_status任务，工作完成了。由于您使用了非零值poll异步状态缓存会自动清除。
3. 由于缓存被清除，作业 ID 不再存在。

上述场景旨在避免目标在长时间运行的任务上超时，而不是同时运行任务并对其状态设置稍后的检查点。对于第二个要求，您需要运行异步任务poll: 0并自行清理缓存

有关上述概念的更多解释，请参阅文档：

• ansible 异步指南
• ansible async_status module

我用您的上述任务做了一个示例，并将其修复为使用专用模块apt（请注意，您可以添加name带有一个或一系列软件包的模块的选项，ansible 将在一个步骤中完成缓存更新和安装）。还，retries * delayasync_status 任务上的值应等于或大于async如果您想确保不会错过最后的任务，请在初始任务上进行。

- name: Update apt cache
  ansible.builtin.apt:
    update_cache: true
  async: 2000
  poll: 0
  register: output

- name: check progress
  ansible.builtin.async_status:
    jid: "{{ output.ansible_job_id }}"
  register: job_result
  until: job_result.finished
  retries: 400
  delay: 5

- name: clean async job cache 
  ansible.builtin.async_status:
    jid: "{{ output.ansible_job_id }}"
    mode: cleanup

这对于并行启动一堆长期持续的任务更有用。这是一个无用但实用的示例：

- name: launch some loooooong tasks
  shell: "{{ item }}"
  loop:
    - sleep 30
    - sleep 20
    - sleep 35
  async: 100
  poll: 0
  register: long_cmd

- name: wait until all commands are done
  async_status:
    jid: "{{ item.ansible_job_id }}"
  register: async_poll_result
  until: async_poll_result.finished
  retries: 50
  delay: 2
  loop: "{{ long_cmd.results }}"

- name: clean async job cache
  async_status:
    jid: "{{ item.ansible_job_id }}"
    mode: cleanup
  loop: "{{ long_cmd.results }}"